fix

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Sep 5, 2024 · 09f04ed · 09f04ed
1 parent 1b632e2
commit 09f04ed
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/integration_tests/twitter-pulsar/pb/create_source.sql b/integration_tests/twitter-pulsar/pb/create_source.sql
@@ -1,5 +1,6 @@
 CREATE SOURCE twitter WITH (
     connector = 'pulsar',
     pulsar.topic = 'twitter',
-    pulsar.service.url = 'pulsar://message_queue:6650'
+    pulsar.service.url = 'pulsar://message_queue:6650',
+    subscription.name.prefix = 'custom_prefix'
 ) ROW FORMAT PROTOBUF MESSAGE 'twitter.schema.Event' ROW SCHEMA LOCATION 'http://file_server:8080/schema';