ref: Use @kafka_options decorator for ingest-consumer cli (#45231)

lynnagara · web-flow · commit 0cdbec61e5dc · 2023-03-01T10:07:23.000-08:00
The @batching_kafka_options decorator will be deprecated in favour of
@kafka_options which supports both batching and non batching mode.
diff --git a/src/sentry/runner/commands/run.py b/src/sentry/runner/commands/run.py
@@ -548,7 +548,7 @@ def batching_kafka_options(
     is_flag=True,
     help="Listen to all consumer types at once.",
 )
-@batching_kafka_options("ingest-consumer", max_batch_size=100)
+@kafka_options("ingest-consumer", include_batching_options=True, default_max_batch_size=100)
 @click.option(
     "--concurrency",
     type=int,

Original file line number	Diff line number	Diff line change
`@@ -548,7 +548,7 @@ def batching_kafka_options(`
`548`	`548`	`is_flag=True,`
`549`	`549`	`help="Listen to all consumer types at once.",`
`550`	`550`	`)`
`551`		`-@batching_kafka_options("ingest-consumer", max_batch_size=100)`
	`551`	`+@kafka_options("ingest-consumer", include_batching_options=True, default_max_batch_size=100)`
`552`	`552`	`@click.option(`
`553`	`553`	`"--concurrency",`
`554`	`554`	`type=int,`