diff --git a/src/sentry/consumers/__init__.py b/src/sentry/consumers/__init__.py index 1737258d125e51..88ac854c52e086 100644 --- a/src/sentry/consumers/__init__.py +++ b/src/sentry/consumers/__init__.py @@ -469,7 +469,6 @@ def get_stream_processor( add_global_tags: bool = False, profile_consumer_join: bool = False, enable_autocommit: bool = False, - retry_handle_destroyed: bool = False, handle_poll_while_paused: bool = False, ) -> StreamProcessor: from sentry.utils import kafka_config @@ -529,7 +528,6 @@ def build_consumer_config(group_id: str): auto_offset_reset=auto_offset_reset, strict_offset_reset=strict_offset_reset, enable_auto_commit=enable_autocommit, - retry_handle_destroyed=retry_handle_destroyed, ) if max_poll_interval_ms is not None: diff --git a/src/sentry/runner/commands/run.py b/src/sentry/runner/commands/run.py index e45be6af8f8c11..e128a8b18fe88a 100644 --- a/src/sentry/runner/commands/run.py +++ b/src/sentry/runner/commands/run.py @@ -556,12 +556,6 @@ def taskbroker_send_tasks( default=False, help="Enable Kafka autocommit mode with 1s commit interval. Offsets are stored via store_offsets and rdkafka commits them automatically.", ) -@click.option( - "--retry-handle-destroyed", - is_flag=True, - default=False, - help="Enable retrying on `KafkaError._DESTROY` during commit.", -) @click.option( "--handle-poll-while-paused", is_flag=True,