capture: fix produce_rtt_latency metric unit (#46)

PostHog · May 30, 2024 · 8d69910 · 8d69910
1 parent ff0780c
commit 8d69910
Showing 1 changed file with 4 additions and 4 deletions.
diff --git 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()
                 )