fix the metrics strategy

getsentry · Mar 5, 2024 · 356da1c · 356da1c
1 parent d40d0fe
commit 356da1c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/sentry/sentry_metrics/consumers/indexer/multiprocess.py b/src/sentry/sentry_metrics/consumers/indexer/multiprocess.py
@@ -27,7 +27,7 @@ def __init__(
         self.__producer = Producer(
             kafka_config.get_kafka_producer_cluster_options(snuba_metrics["cluster"]),
         )
-        self.__producer_topic = output_topic
+        self.__producer_topic = snuba_metrics["real_topic_name"]
         self.__commit_function = commit_function
 
         self.__closed = False