rust too

getsentry · Dec 24, 2024 · 559b7ca · 559b7ca
1 parent 213f30c
commit 559b7ca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/rust-arroyo/src/processing/dlq.rs b/rust-arroyo/src/processing/dlq.rs
@@ -15,7 +15,7 @@ use crate::gauge;
 use crate::types::{BrokerMessage, Partition, Topic, TopicOrPartition};
 
 // This is a per-partition max
-const MAX_PENDING_FUTURES: usize = 1000;
+const MAX_PENDING_FUTURES: usize = 2000;
 
 pub trait DlqProducer<TPayload>: Send + Sync {
     // Send a message to the DLQ.