ref(ingest-replay-recordings): Remove unused consumer args (#45175)

getsentry · Feb 28, 2023 · 04032e8 · 04032e8
1 parent 1702653
commit 04032e8
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/src/sentry/replays/consumers/__init__.py b/src/sentry/replays/consumers/__init__.py
@@ -16,11 +16,9 @@
 def get_replays_recordings_consumer(
     topic: str,
     group_id: str,
-    max_batch_size: int,
     auto_offset_reset: str,
     force_topic: str | None,
     force_cluster: str | None,
-    **options: dict[str, str],
 ) -> StreamProcessor[KafkaPayload]:
     topic = force_topic or topic
     consumer_config = get_config(topic, group_id, auto_offset_reset, force_cluster)

diff --git a/src/sentry/runner/commands/run.py b/src/sentry/runner/commands/run.py
@@ -690,7 +690,7 @@ def profiles_consumer(**options):
 @run.command("ingest-replay-recordings")
 @log_options()
 @configuration
-@batching_kafka_options("ingest-replay-recordings", max_batch_size=100)
+@kafka_options("ingest-replay-recordings")
 @click.option(
     "--topic", default="ingest-replay-recordings", help="Topic to get replay recording data from"
 )