ref(metrics): Change metrics topic name (#2089)

* ref(metrics): Change metrics topic name * add LogAppendTime
getsentry · Sep 28, 2021 · 63db117 · 63db117
1 parent 846aff0
commit 63db117
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/snuba/settings/validation.py b/snuba/settings/validation.py
@@ -24,7 +24,7 @@ def _validate_settings(locals: Mapping[str, Any]) -> None:
         "event-replacements-legacy",
         "snuba-commit-log",
         "cdc",
-        "ingest-metrics",
+        "snuba-metrics",
         "outcomes",
         "ingest-sessions",
         "snuba-queries",

diff --git a/snuba/utils/streams/topics.py b/snuba/utils/streams/topics.py
@@ -11,7 +11,7 @@ class Topic(Enum):
     EVENT_REPLACEMENTS_LEGACY = "event-replacements-legacy"
     COMMIT_LOG = "snuba-commit-log"
     CDC = "cdc"
-    METRICS = "ingest-metrics"
+    METRICS = "snuba-metrics"
     OUTCOMES = "outcomes"
     SESSIONS = "ingest-sessions"
     SESSIONS_COMMIT_LOG = "snuba-sessions-commit-log"
@@ -22,7 +22,10 @@ class Topic(Enum):
 
 
 def get_topic_creation_config(topic: Topic) -> Mapping[str, str]:
-    config = {Topic.EVENTS: {"message.timestamp.type": "LogAppendTime"}}
+    config = {
+        Topic.EVENTS: {"message.timestamp.type": "LogAppendTime"},
+        Topic.METRICS: {"message.timestamp.type": "LogAppendTime"},
+    }
     if settings.ENABLE_SESSIONS_SUBSCRIPTIONS:
         config.update({Topic.SESSIONS: {"message.timestamp.type": "LogAppendTime"}})
     return config.get(topic, {})