From addb26e28a84e3d0e5da0027c3d0131996e682bf Mon Sep 17 00:00:00 2001 From: "mergify[bot]" <37929162+mergify[bot]@users.noreply.github.com> Date: Fri, 31 Jan 2025 16:25:30 -0600 Subject: [PATCH] Add Kafka output metrics (#42537) (#42556) (cherry picked from commit 2b8d554d3169807a35e32702833e83935a6adac0) Co-authored-by: William Easton --- libbeat/outputs/kafka/config.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/libbeat/outputs/kafka/config.go b/libbeat/outputs/kafka/config.go index c7dc74ee9934..61fd5bb2aedb 100644 --- a/libbeat/outputs/kafka/config.go +++ b/libbeat/outputs/kafka/config.go @@ -306,11 +306,14 @@ func newSaramaConfig(log *logp.Logger, config *kafkaConfig) (*sarama.Config, err k.Version = version k.Producer.Partitioner = partitioner + k.MetricRegistry = adapter.GetGoMetrics( monitoring.Default, - "libbeat.outputs.kafka", - adapter.Rename("incoming-byte-rate", "bytes_read"), - adapter.Rename("outgoing-byte-rate", "bytes_write"), + "libbeat.outputs", + adapter.Rename("incoming-byte-rate", "read.bytes"), + adapter.Rename("outgoing-byte-rate", "write.bytes"), + adapter.Rename("request-latency-in-ms", "write.latency"), + adapter.Rename("requests-in-flight", "kafka.requests-in-flight"), adapter.GoMetricsNilify, )