feat(replay): add config for new topic ingest-feedback-events (#66484)

Linked to #66100 and https://getsentry.atlassian.net/browse/OPS-5317 Dependent on: [sentry-kafka-schemas PR](getsentry/sentry-kafka-schemas#227)
getsentry · Mar 13, 2024 · 9ab40c3 · 9ab40c3
1 parent 9519c29
commit 9ab40c3
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 0 deletions.
diff --git a/src/sentry/conf/server.py b/src/sentry/conf/server.py
@@ -3496,6 +3496,7 @@ def build_cdc_postgres_init_db_volume(settings: Any) -> dict[str, dict[str, str]
     "sessions-subscription-results": "default",
     "metrics-subscription-results": "default",
     "ingest-events": "default",
+    "ingest-feedback-events": "default",
     "ingest-attachments": "default",
     "ingest-transactions": "default",
     "ingest-metrics": "default",

diff --git a/src/sentry/conf/types/kafka_definition.py b/src/sentry/conf/types/kafka_definition.py
@@ -26,6 +26,7 @@ class Topic(Enum):
     METRICS_SUBSCRIPTIONS_RESULTS = "metrics-subscription-results"
     INGEST_EVENTS = "ingest-events"
     INGEST_EVENTS_DLQ = "ingest-events-dlq"
+    INGEST_FEEDBACK_EVENTS = "ingest-feedback-events"
     INGEST_ATTACHMENTS = "ingest-attachments"
     INGEST_TRANSACTIONS = "ingest-transactions"
     INGEST_METRICS = "ingest-metrics"

diff --git a/src/sentry/consumers/__init__.py b/src/sentry/consumers/__init__.py
@@ -260,6 +260,14 @@ def ingest_events_options() -> list[click.Option]:
             "consumer_type": "events",
         },
     },
+    "ingest-feedback-events": {
+        "topic": Topic.INGEST_FEEDBACK_EVENTS,
+        "strategy_factory": "sentry.ingest.consumer.factory.IngestStrategyFactory",
+        "click_options": ingest_events_options(),
+        "static_args": {
+            "consumer_type": "feedback-events",
+        },
+    },
     "ingest-attachments": {
         "topic": Topic.INGEST_ATTACHMENTS,
         "strategy_factory": "sentry.ingest.consumer.factory.IngestStrategyFactory",

diff --git a/src/sentry/ingest/types.py b/src/sentry/ingest/types.py
@@ -6,3 +6,4 @@ class ConsumerType:
     Events = "events"  # consumes simple events ( from the Events topic)
     Attachments = "attachments"  # consumes events with attachments ( from the Attachments topic)
     Transactions = "transactions"  # consumes transaction events ( from the Transactions topic)
+    FeedbackEvents = "feedback-events"  # consumes user feedback events ( from the Feedbacks topic)