Browse Source

feat(ourlogs): Add kafka topic definition and default cluster (#83837)

This adds the snuba-ourlogs topic to the kafka definitions, which get
added to self-hosted when upgrading
[here](https://github.com/getsentry/sentry/blob/bdd408284ed1ddfd8b902553b25dd87ddad6608c/src/sentry/runner/commands/upgrade.py\#L81-L83).

Blocked by https://github.com/getsentry/getsentry/pull/16220
Kev 1 month ago
parent
commit
9470241b3a
2 changed files with 2 additions and 0 deletions
  1. 1 0
      src/sentry/conf/server.py
  2. 1 0
      src/sentry/conf/types/kafka_definition.py

+ 1 - 0
src/sentry/conf/server.py

@@ -2969,6 +2969,7 @@ KAFKA_TOPIC_TO_CLUSTER: Mapping[str, str] = {
     "buffered-segments": "default",
     "buffered-segments-dlq": "default",
     "task-worker": "default",
+    "snuba-ourlogs": "default",
 }
 
 

+ 1 - 0
src/sentry/conf/types/kafka_definition.py

@@ -58,6 +58,7 @@ class Topic(Enum):
     GROUP_ATTRIBUTES = "group-attributes"
     SHARED_RESOURCES_USAGE = "shared-resources-usage"
     SNUBA_SPANS = "snuba-spans"
+    SNUBA_OURLOGS = "snuba-ourlogs"
     BUFFERED_SEGMENTS = "buffered-segments"
     BUFFERED_SEGMENTS_DLQ = "buffered-segments-dlq"
     TASK_WORKER = "task-worker"