Reset mqtt broker in e2e test to mqtt-server instead of localhost

risingwavelabs · Oct 23, 2024 · d3a6caf · d3a6caf
1 parent ae9f988
commit d3a6caf
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/e2e_test/sink/mqtt_sink.slt b/e2e_test/sink/mqtt_sink.slt
@@ -21,7 +21,7 @@ FROM
 WITH
   (
     connector='mqtt',
-    url='tcp://127.0.0.1',
+    url='tcp://mqtt-server',
     type = 'append-only',
     topic.field = 'topic',
     retain = 'true',
@@ -37,7 +37,7 @@ FROM
 WITH
   (
     connector='mqtt',
-    url='tcp://127.0.0.1',
+    url='tcp://mqtt-server',
     type = 'append-only',
     topic = '/nested/fallback',
     topic.field = 'info.topic',
@@ -85,7 +85,7 @@ CREATE TABLE mqtt_source
 INCLUDE partition AS mqtt_topic
 WITH (
     connector ='mqtt',
-    url ='tcp://127.0.0.1',
+    url ='tcp://mqtt-server',
     topic = '/device/+',
     qos = 'at_least_once',
 ) FORMAT PLAIN ENCODE JSON;
@@ -98,7 +98,7 @@ CREATE TABLE mqtt_nested_source
 )
 WITH (
     connector='mqtt',
-    url='tcp://127.0.0.1',
+    url='tcp://mqtt-server',
     topic= '/nested/fallback',
     qos = 'at_least_once',
 ) FORMAT PLAIN ENCODE JSON;