diff --git a/e2e_test/source/basic/alter/rate_limit_source_kafka.slt b/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
index a4a2061e2b1f7..918a49e8aa4b7 100644
--- a/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
+++ b/e2e_test/source/basic/alter/rate_limit_source_kafka.slt
@@ -12,7 +12,7 @@ statement ok
 create sink kafka_sink
 from
   kafka_seed_data with (
-    properties.bootstrap.server = 'localhost:29092',
+    properties.bootstrap.server = 'message_queue:29092',
     topic = 'kafka_source',
     type = 'append-only',
     force_append_only='true',
@@ -29,7 +29,7 @@ statement ok
 create source kafka_source (v1 int) with (
   connector = 'kafka',
   topic = 'kafka_source',
-  properties.bootstrap.server = 'localhost:29092',
+  properties.bootstrap.server = 'message_queue:29092',
   scan.startup.mode = 'earliest',
 ) FORMAT PLAIN ENCODE JSON
 
diff --git a/e2e_test/source/basic/alter/rate_limit_table_kafka.slt b/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
index ba96e5c0327f2..bf1fd6672d6ea 100644
--- a/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
+++ b/e2e_test/source/basic/alter/rate_limit_table_kafka.slt
@@ -12,7 +12,7 @@ statement ok
 create sink kafka_sink
 from
   kafka_seed_data with (
-    properties.bootstrap.server = 'localhost:29092',
+    properties.bootstrap.server = 'message_queue:29092',
     topic = 'kafka_source',
     type = 'append-only',
     force_append_only='true',
@@ -25,7 +25,7 @@ statement ok
 create table kafka_source (v1 int) with (
   connector = 'kafka',
   topic = 'kafka_source',
-  properties.bootstrap.server = 'localhost:29092',
+  properties.bootstrap.server = 'message_queue:29092',
   scan.startup.mode = 'earliest',
   streaming_rate_limit = 0
 ) FORMAT PLAIN ENCODE JSON