diff --git a/src/sentry/conf/server.py b/src/sentry/conf/server.py index 9729d5cddc75a3..e3f01724b4c029 100644 --- 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 index ecb0043e402a2e..2bdf08bad8684f 100644 --- 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 index 689442ea7f2198..df9311ea9efc45 100644 --- 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 index 0f07507dd8ef43..5fb66c5df008e2 100644 --- 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)