diff --git a/snuba/consumers/consumer_builder.py b/snuba/consumers/consumer_builder.py index 77f98fb6b6..d9edb6df16 100644 --- a/snuba/consumers/consumer_builder.py +++ b/snuba/consumers/consumer_builder.py @@ -268,6 +268,7 @@ def build_dlq_strategy_factory( processor, self.consumer_group, logical_topic, + self.__enforce_schema, ), collector=build_batch_writer( table_writer,