add LogAppendTime

getsentry · Sep 24, 2021 · 64fe3d4 · 64fe3d4
1 parent 8359ff3
commit 64fe3d4
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/snuba/utils/streams/topics.py b/snuba/utils/streams/topics.py
@@ -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, {})