remove insert batch time/size

getsentry · Nov 5, 2024 · 1d34006 · 1d34006
1 parent a2a188f
commit 1d34006
Showing 1 changed file with 4 additions and 6 deletions.
diff --git a/snuba/cli/lw_deletions_consumer.py b/snuba/cli/lw_deletions_consumer.py
@@ -69,10 +69,8 @@ def lw_deletions_consumer(
     consumer_group: str,
     bootstrap_servers: Sequence[str],
     storage_name: str,
-    max_batch_size: int = 6,
-    max_batch_time_ms: int = 1000,
-    max_insert_batch_size: int = 0,
-    max_insert_batch_time_ms: int = 0,
+    max_batch_size: int,
+    max_batch_time_ms: int,
     auto_offset_reset: str,
     no_strict_offset_reset: bool,
     queued_max_messages_kbytes: int,
@@ -135,8 +133,8 @@ def handler(signum: int, frame: Any) -> None:
             processing_params=ProcessingParameters(None, None, None),
             max_batch_size=max_batch_size,
             max_batch_time_ms=max_batch_time_ms,
-            max_insert_batch_size=max_insert_batch_size,
-            max_insert_batch_time_ms=max_insert_batch_time_ms,
+            max_insert_batch_size=0,
+            max_insert_batch_time_ms=0,
             metrics=metrics,
             slice_id=None,
             join_timeout=None,