fix(statsd): Prefix kafka client metrics (#3341)

There was a naming collision for `kafka.message_size`, so I'm prefixing all client stats.
getsentry · Mar 27, 2024 · 1f94761 · 1f94761
1 parent 82e76b1
commit 1f94761
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/relay-kafka/src/statsd.rs b/relay-kafka/src/statsd.rs
@@ -86,14 +86,14 @@ impl GaugeMetric for KafkaGauges {
     fn name(&self) -> &'static str {
         match self {
             KafkaGauges::InFlightCount => "kafka.in_flight_count",
-            KafkaGauges::MessageCount => "kafka.message_count",
-            KafkaGauges::MessageCountMax => "kafka.message_count_max",
-            KafkaGauges::MessageSize => "kafka.message_size",
-            KafkaGauges::MessageSizeMax => "kafka.message_size_max",
-            KafkaGauges::OutboundBufferRequests => "kafka.broker.outbuf.requests",
-            KafkaGauges::OutboundBufferMessages => "kafka.broker.outbuf.messages",
-            KafkaGauges::Connects => "kafka.broker.connects",
-            KafkaGauges::Disconnects => "kafka.broker.disconnects",
+            KafkaGauges::MessageCount => "kafka.stats.message_count",
+            KafkaGauges::MessageCountMax => "kafka.stats.message_count_max",
+            KafkaGauges::MessageSize => "kafka.stats.message_size",
+            KafkaGauges::MessageSizeMax => "kafka.stats.message_size_max",
+            KafkaGauges::OutboundBufferRequests => "kafka.stats.broker.outbuf.requests",
+            KafkaGauges::OutboundBufferMessages => "kafka.stats.broker.outbuf.messages",
+            KafkaGauges::Connects => "kafka.stats.broker.connects",
+            KafkaGauges::Disconnects => "kafka.stats.broker.disconnects",
         }
     }
 }