From 09f04ed067dca4bc2047577712e8e2768f2fae70 Mon Sep 17 00:00:00 2001 From: tabVersion Date: Thu, 5 Sep 2024 16:54:51 +0800 Subject: [PATCH] fix Signed-off-by: tabVersion --- integration_tests/twitter-pulsar/pb/create_source.sql | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/integration_tests/twitter-pulsar/pb/create_source.sql b/integration_tests/twitter-pulsar/pb/create_source.sql index bf41939b40d9..22c4927ab3bb 100644 --- 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'; \ No newline at end of file