fix

risingwavelabs · Apr 29, 2024 · 9850cfb · 9850cfb
1 parent 0576a14
commit 9850cfb
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git 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
@@ -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