Add python consumer flag

snuba/cli/rust_consumer.py

@@ -148,6 +148,11 @@
     This is only to be used for the mutability consumer
     """,
 )
+@click.option(
+    "--max-dlq-buffer-size",
+    default=None,
+    help="Set a per-partition limit to the size (length) of the DLQ buffer",
+)
 @click.option(
     "--health-check-file",
     default=None,
@@ -212,7 +217,8 @@ def rust_consumer(
     stop_at_timestamp: Optional[int],
     batch_write_timeout_ms: Optional[int],
     max_bytes_before_external_group_by: Optional[int],
-    mutations_mode: bool
+    mutations_mode: bool,
+    max_dlq_buffer_size: Optional[int]
 ) -> None:
     """
     Experimental alternative to `snuba consumer`
@@ -265,6 +271,7 @@ def rust_consumer(
         stop_at_timestamp,
         batch_write_timeout_ms,
         max_bytes_before_external_group_by,
+        max_dlq_buffer_size,
     )
 
     sys.exit(exitcode)