diff --git a/rust_snuba/src/consumer.rs b/rust_snuba/src/consumer.rs index 21a8c549e7..79a9547b19 100644 --- a/rust_snuba/src/consumer.rs +++ b/rust_snuba/src/consumer.rs @@ -166,8 +166,8 @@ pub fn consumer_impl( handle, kafka_dlq_producer, DlqLimit { - max_invalid_ratio: Some(0.01), - max_consecutive_count: Some(1000), + max_invalid_ratio: None, + max_consecutive_count: None, }, None, ) diff --git a/snuba/consumers/consumer_builder.py b/snuba/consumers/consumer_builder.py index 928e88cc85..1571e06ccc 100644 --- a/snuba/consumers/consumer_builder.py +++ b/snuba/consumers/consumer_builder.py @@ -396,8 +396,8 @@ def __build_default_dlq_policy(self) -> Optional[DlqPolicy[KafkaPayload]]: Topic(self.__consumer_config.dlq_topic.physical_topic_name), ), DlqLimit( - max_invalid_ratio=0.01, - max_consecutive_count=1000, + max_invalid_ratio=None, + max_consecutive_count=None, ), None, )