fix

risingwavelabs · Jul 26, 2023 · 27aba9e · 27aba9e
1 parent 71dfb1d
commit 27aba9e
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/e2e_test/source/basic/kafka.slt b/e2e_test/source/basic/kafka.slt
@@ -778,7 +778,7 @@ create table s25 (v1 int, v2 varchar) with (
   properties.bootstrap.server = 'message_queue:29092',
   scan.startup.mode = 'earliest',
   properties.fetch.queue.backoff.ms = 250,
-  properties.queued.min.messages = 10000
+  properties.queued.max.messages.kbytes = 65536
 ) FORMAT PLAIN ENCODE JSON
 
 query I

diff --git a/src/connector/src/source/kafka/mod.rs b/src/connector/src/source/kafka/mod.rs
@@ -62,6 +62,7 @@ pub struct RdKafkaProperties {
     /// exceeded. This property may need to be decreased if the queue thresholds are set low
     /// and the application is experiencing long (~1s) delays between messages. Low values may
     /// increase CPU utilization.
+    // FIXME: need to upgrade rdkafka to v2.2.0 to use this property
     #[serde(rename = "properties.fetch.queue.backoff.ms")]
     #[serde_as(as = "Option<DisplayFromStr>")]
     pub fetch_queue_backoff_ms: Option<usize>,