increase consumer queue size

Bot-detector · Jul 16, 2024 · 6aba53d · 6aba53d
1 parent 33f4982
commit 6aba53d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/_kafka.py b/src/_kafka.py
@@ -5,7 +5,7 @@
 consumer = ConsumerEngine(
     bootstrap_servers=[settings.KAFKA_HOST],
     group_id="report-worker",
-    queue_size=100,
+    queue_size=10_000,
     report_interval=60,
 )
 producer = ProducerEngine(