test: fix pulsar test - expired credential (#17152)

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Jun 6, 2024 · 8167519 · 8167519
1 parent 2db86b0
commit 8167519
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/e2e_test/source/pulsar/astra-streaming.py b/e2e_test/source/pulsar/astra-streaming.py
@@ -20,7 +20,7 @@ def do_test(config):
     cur.execute(f'''CREATE TABLE t (v1 int, v2 varchar)
                     WITH (
                     connector='pulsar',
-                    topic='persistent://tenant0/default/topic0',
+                    topic='persistent://meetup/default/ci-test',
                     service.url='pulsar+ssl://pulsar-gcp-useast1.streaming.datastax.com:6651',
                     auth.token='{config['ASTRA_STREAMING_TOKEN']}'
                     )

diff --git a/e2e_test/source/pulsar/pulsar.slt b/e2e_test/source/pulsar/pulsar.slt
@@ -1,8 +1,9 @@
 query IT nosort
 select * FROM t;
 ----
-1 name0
-2 name0
-6 name3
-0 name5
-5 name8
+1 name1
+2 name2
+3 name3
+4 name4
+5 name5
+6 name6