From 8d69910b091cb2b9ff2ada1a2946b92804983c89 Mon Sep 17 00:00:00 2001
From: Xavier Vello <xavier@posthog.com>
Date: Thu, 30 May 2024 15:59:20 +0200
Subject: [PATCH] capture: fix produce_rtt_latency metric unit (#46)

---
 capture/src/sinks/kafka.rs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/capture/src/sinks/kafka.rs b/capture/src/sinks/kafka.rs
index bff61b5..b82d3c3 100644
--- a/capture/src/sinks/kafka.rs
+++ b/capture/src/sinks/kafka.rs
@@ -50,25 +50,25 @@ impl rdkafka::ClientContext for KafkaContext {
             let id_string = format!("{}", stats.nodeid);
             if let Some(rtt) = stats.rtt {
                 gauge!(
-                    "capture_kafka_produce_rtt_latency_ms",
+                    "capture_kafka_produce_rtt_latency_us",
                     "quantile" => "p50",
                     "broker" => id_string.clone()
                 )
                 .set(rtt.p50 as f64);
                 gauge!(
-                    "capture_kafka_produce_rtt_latency_ms",
+                    "capture_kafka_produce_rtt_latency_us",
                     "quantile" => "p90",
                     "broker" => id_string.clone()
                 )
                 .set(rtt.p90 as f64);
                 gauge!(
-                    "capture_kafka_produce_rtt_latency_ms",
+                    "capture_kafka_produce_rtt_latency_us",
                     "quantile" => "p95",
                     "broker" => id_string.clone()
                 )
                 .set(rtt.p95 as f64);
                 gauge!(
-                    "capture_kafka_produce_rtt_latency_ms",
+                    "capture_kafka_produce_rtt_latency_us",
                     "quantile" => "p99",
                     "broker" => id_string.clone()
                 )