feat(spans): Add DLQ topic for buffered spans (#68571)

Add DLQ to buffered-segments topic
getsentry · Apr 18, 2024 · 27d14db · 27d14db
1 parent ebb2016
commit 27d14db
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/src/sentry/conf/server.py b/src/sentry/conf/server.py
@@ -3484,6 +3484,7 @@ def build_cdc_postgres_init_db_volume(settings: Any) -> dict[str, dict[str, str]
     "snuba-spans": "default",
     "shared-resources-usage": "default",
     "buffered-segments": "default",
+    "buffered-segments-dlq": "default",
 }
 
 

diff --git a/src/sentry/conf/types/kafka_definition.py b/src/sentry/conf/types/kafka_definition.py
@@ -48,6 +48,7 @@ class Topic(Enum):
     SHARED_RESOURCES_USAGE = "shared-resources-usage"
     SNUBA_SPANS = "snuba-spans"
     BUFFERED_SEGMENTS = "buffered-segments"
+    BUFFERED_SEGMENTS_DLQ = "buffered-segments-dlq"
 
 
 class ConsumerDefinition(TypedDict, total=False):

diff --git a/src/sentry/consumers/__init__.py b/src/sentry/consumers/__init__.py
@@ -349,6 +349,7 @@ def ingest_events_options() -> list[click.Option]:
         "topic": Topic.BUFFERED_SEGMENTS,
         "strategy_factory": "sentry.spans.consumers.detect_performance_issues.factory.DetectPerformanceIssuesStrategyFactory",
         "click_options": multiprocessing_options(default_max_batch_size=100),
+        "dlq_topic": Topic.BUFFERED_SEGMENTS_DLQ,
     },
     **settings.SENTRY_KAFKA_CONSUMERS,
 }