From 4f69bc5402097eb70a49e232957c2c9af15e2ccf Mon Sep 17 00:00:00 2001 From: Evan Hicks Date: Tue, 10 Nov 2026 16:58:41 -0500 Subject: [PATCH 1/2] ref(INC-2690): Reduce the partition queue memory fetch even further --- src/config/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/config/mod.rs b/src/config/mod.rs index af0ef231..b2fe90ce 100644 --- a/src/config/mod.rs +++ b/src/config/mod.rs @@ -291,7 +291,7 @@ impl Default for Config { kafka_session_timeout_ms: 6000, kafka_auto_commit_interval_ms: 5000, kafka_auto_offset_reset: "latest".to_owned(), - kafka_queued_max_messages_kbytes: 16384, + kafka_queued_max_messages_kbytes: 4096, kafka_send_timeout_ms: 500, store: StoreConfig::default(), runtime_config_path: None, From d81bd4da7c72f7f6603c5695395242c3f385a0bd Mon Sep 17 00:00:00 2001 From: Evan Hicks Date: Tue, 10 Nov 2026 17:14:49 -0500 Subject: [PATCH 2/2] update test --- src/config/mod.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/config/mod.rs b/src/config/mod.rs index b2fe90ce..201706bf 100644 --- a/src/config/mod.rs +++ b/src/config/mod.rs @@ -1490,7 +1490,7 @@ mod tests { assert!(consumer_config.get("session.timeout.ms").is_some()); assert_eq!( consumer_config.get("queued.max.messages.kbytes").unwrap(), - "16384" + "4096" ); }