fix: DEFAULT_QUEUE_BUFFERING_MAX_MS (#15)

Lambda256 · Jan 9, 2025 · 3b61cae · 3b61cae
1 parent 34f5e0b
commit 3b61cae
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rust/processor/src/utils/mq.rs b/rust/processor/src/utils/mq.rs
@@ -4,7 +4,7 @@ use rdkafka::{
 };
 
 const DEFAULT_MESSAGE_TIMEOUT_MS: &str = "5000";
-const DEFAULT_QUEUE_BUFFERING_MAX_MS: &str = "2000";
+const DEFAULT_QUEUE_BUFFERING_MAX_MS: &str = "100";
 
 pub trait CustomProducer {
     fn new(brokers: &str) -> Self;