Skip to content
This repository has been archived by the owner on Jun 21, 2024. It is now read-only.

capture: fix produce_rtt_latency metric unit #46

Merged
merged 2 commits into from
May 30, 2024
Merged

capture: fix produce_rtt_latency metric unit #46

Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f9ad550
capture: fix produce_rtt_latency metric unit
xvello May 30, 2024
b908b0f
Update kafka.rs
xvello May 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions capture/src/sinks/kafka.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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()
)
Expand Down
Loading