diff --git a/backwards-compat-tests/scripts/run_local.sh b/backwards-compat-tests/scripts/run_local.sh
index 313aca71ba49..20e820ef3e09 100755
--- a/backwards-compat-tests/scripts/run_local.sh
+++ b/backwards-compat-tests/scripts/run_local.sh
@@ -25,8 +25,8 @@ full-without-monitoring:
     - use: compactor
     - use: kafka
       user-managed: true
-      address: kafka
-      port: 9093
+      address: message_queue
+      port: 29092
 EOF
 
 cat <<EOF > risedev-components.user.env
diff --git a/backwards-compat-tests/scripts/utils.sh b/backwards-compat-tests/scripts/utils.sh
index 308c58ad9400..6b5184b2bb0e 100644
--- a/backwards-compat-tests/scripts/utils.sh
+++ b/backwards-compat-tests/scripts/utils.sh
@@ -78,7 +78,7 @@ check_version() {
 }
 
 create_kafka_topic() {
-  RPK_BROKERS=kafka:9093 \
+  RPK_BROKERS=message_queue:29092 \
   rpk topic create backwards_compat_test_kafka_source
 }
 
@@ -86,7 +86,7 @@ insert_json_kafka() {
   local JSON=$1
 
   echo "$JSON" | \
-  RPK_BROKERS=kafka:9093 \
+  RPK_BROKERS=message_queue:29092 \
   rpk topic produce backwards_compat_test_kafka_source -f "%k,%v"
 }
 
diff --git a/backwards-compat-tests/slt/kafka/invalid_options/seed.slt b/backwards-compat-tests/slt/kafka/invalid_options/seed.slt
index 975c3a405e71..2fef943c8ab4 100644
--- a/backwards-compat-tests/slt/kafka/invalid_options/seed.slt
+++ b/backwards-compat-tests/slt/kafka/invalid_options/seed.slt
@@ -14,7 +14,7 @@ CREATE SOURCE IF NOT EXISTS kafka_source_with_invalid_option
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
  invalid_option='oops'
 ) FORMAT PLAIN ENCODE JSON;
diff --git a/backwards-compat-tests/slt/kafka/seed.slt b/backwards-compat-tests/slt/kafka/seed.slt
index 317063226628..aa2a196694e4 100644
--- a/backwards-compat-tests/slt/kafka/seed.slt
+++ b/backwards-compat-tests/slt/kafka/seed.slt
@@ -11,7 +11,7 @@ CREATE SOURCE IF NOT EXISTS kafka_source
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT PLAIN ENCODE JSON;
 
diff --git a/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt b/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt
index cfce84b0573b..57f1e2d27391 100644
--- a/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt
+++ b/backwards-compat-tests/slt/kafka/upsert/deprecate_upsert.slt
@@ -11,6 +11,6 @@ CREATE TABLE IF NOT EXISTS kafka_table
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT UPSERT ENCODE JSON;
diff --git a/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt b/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt
index 3f015a44c360..37d41e195ee0 100644
--- a/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt
+++ b/backwards-compat-tests/slt/kafka/upsert/include_key_as.slt
@@ -13,6 +13,6 @@ INCLUDE key as _rw_key
 WITH (
  connector='kafka',
  topic='backwards_compat_test_kafka_source',
- properties.bootstrap.server='kafka:9093',
+ properties.bootstrap.server='message_queue:29092',
  scan.startup.mode='earliest',
 ) FORMAT UPSERT ENCODE JSON;
diff --git a/ci/workflows/main-cron.yml b/ci/workflows/main-cron.yml
index 7e5a386d498a..3c46909b0a46 100644
--- a/ci/workflows/main-cron.yml
+++ b/ci/workflows/main-cron.yml
@@ -654,7 +654,7 @@ steps:
       - "build"
     plugins:
       - docker-compose#v5.1.0:
-          run: rw-build-env
+          run: source-test-env
           config: ci/docker-compose.yml
           mount-buildkite-agent: true
       - ./ci/plugins/upload-failure-logs
diff --git a/ci/workflows/pull-request.yml b/ci/workflows/pull-request.yml
index c19b9a774fc1..1cc1a1054b0b 100644
--- a/ci/workflows/pull-request.yml
+++ b/ci/workflows/pull-request.yml
@@ -642,7 +642,7 @@ steps:
       - "build"
     plugins:
       - docker-compose#v5.1.0:
-          run: rw-build-env
+          run: source-test-env
           config: ci/docker-compose.yml
           mount-buildkite-agent: true
       - ./ci/plugins/upload-failure-logs