update

risingwavelabs · Apr 11, 2024 · 6ed6cfc · 6ed6cfc
1 parent f7a3dd5
commit 6ed6cfc
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/e2e_test/source_new/kafka/test_1.slt b/e2e_test/source_new/kafka/test_1.slt
@@ -9,6 +9,7 @@ cat <<EOF | ./risedev rpk topic produce source_new_test_1 -f "%p %v\\n" -p 0
 0 {"x":"a"}
 1 {"x":"b"}
 2 {"x":"c"}
+EOF
 
 statement ok
 CREATE SOURCE s(x varchar)
@@ -44,11 +45,11 @@ DROP SOURCE s CASCADE;
 system ok
 ./risedev rpk group list
 ----
+0       rw-consumer-1-1
+0       rw-consumer-1-2
+0       rw-consumer-1-3
+0       rw-consumer-4294967295-4294967295
 
 
-
-
-
-
-# system ok
-# ./risedev rpk topic delete source_new_test_1
+system ok
+./risedev rpk topic delete source_new_test_1
diff --git a/src/risedevtool/src/risedev_env.rs b/src/risedevtool/src/risedev_env.rs
@@ -69,7 +69,7 @@ pub fn generate_risedev_env(services: &Vec<ServiceConfig>) -> String {
             }
             ServiceConfig::Kafka(c) => {
                 let brokers = format!("{}:{}", c.address, c.port);
-                writeln!(env, r#"RISEDEV_KAFKA_BOOTSTRAP_SERVERS='{brokers}'"",).unwrap();
+                writeln!(env, r#"RISEDEV_KAFKA_BOOTSTRAP_SERVERS="{brokers}""#,).unwrap();
                 writeln!(env, r#"RISEDEV_KAFKA_WITH_OPTIONS_COMMON="connector='kafka',properties.bootstrap.server='{brokers}'""#).unwrap();
             }
             _ => {}