feat(billing): Introduce Outcomes Dead Letter Queue type (#73334)

Introduce `Topic.OUTCOMES_DLQ` and `Topic.OUTCOMES_BILLING_DLQ` to be used for the dead letter queue on the outcomes consumer. For getsentry/getsentry#14437
getsentry · Jul 30, 2024 · d0505f0 · d0505f0
1 parent 8aea881
commit d0505f0
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 3 deletions.
diff --git a/requirements-base.txt b/requirements-base.txt
@@ -62,7 +62,7 @@ rfc3339-validator>=0.1.2
 rfc3986-validator>=0.1.1
 # [end] jsonschema format validators
 sentry-arroyo>=2.16.5
-sentry-kafka-schemas>=0.1.101
+sentry-kafka-schemas>=0.1.102
 sentry-ophio==0.2.7
 sentry-redis-tools>=0.1.7
 sentry-relay>=0.9.1

diff --git a/requirements-dev-frozen.txt b/requirements-dev-frozen.txt
@@ -182,7 +182,7 @@ sentry-cli==2.16.0
 sentry-devenv==1.7.0
 sentry-forked-django-stubs==5.0.2.post8
 sentry-forked-djangorestframework-stubs==3.15.0.post1
-sentry-kafka-schemas==0.1.101
+sentry-kafka-schemas==0.1.102
 sentry-ophio==0.2.7
 sentry-redis-tools==0.1.7
 sentry-relay==0.9.1

diff --git a/requirements-frozen.txt b/requirements-frozen.txt
@@ -123,7 +123,7 @@ rpds-py==0.15.2
 rsa==4.8
 s3transfer==0.10.0
 sentry-arroyo==2.16.5
-sentry-kafka-schemas==0.1.101
+sentry-kafka-schemas==0.1.102
 sentry-ophio==0.2.7
 sentry-redis-tools==0.1.7
 sentry-relay==0.9.1

diff --git a/src/sentry/conf/server.py b/src/sentry/conf/server.py
@@ -2855,7 +2855,9 @@ def custom_parameter_sort(parameter: dict) -> tuple[str, int]:
     "transactions": "default",
     "snuba-transactions-commit-log": "default",
     "outcomes": "default",
+    "outcomes-dlq": "default",
     "outcomes-billing": "default",
+    "outcomes-billing-dlq": "default",
     "events-subscription-results": "default",
     "transactions-subscription-results": "default",
     "generic-metrics-subscription-results": "default",

diff --git a/src/sentry/conf/types/kafka_definition.py b/src/sentry/conf/types/kafka_definition.py
@@ -19,7 +19,9 @@ class Topic(Enum):
     TRANSACTIONS = "transactions"
     TRANSACTIONS_COMMIT_LOG = "snuba-transactions-commit-log"
     OUTCOMES = "outcomes"
+    OUTCOMES_DLQ = "outcomes-dlq"
     OUTCOMES_BILLING = "outcomes-billing"
+    OUTCOMES_BILLING_DLQ = "outcomes-billing-dlq"
     EVENTS_SUBSCRIPTIONS_RESULTS = "events-subscription-results"
     TRANSACTIONS_SUBSCRIPTIONS_RESULTS = "transactions-subscription-results"
     GENERIC_METRICS_SUBSCRIPTIONS_RESULTS = "generic-metrics-subscription-results"