From 2436cb8e550837b62db1615a1012ae657f6ad7dc Mon Sep 17 00:00:00 2001 From: William Easton Date: Fri, 31 Jan 2025 14:20:49 -0600 Subject: [PATCH] Add Kafka output metrics (#42537) (cherry picked from commit 2b8d554d3169807a35e32702833e83935a6adac0) --- 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 98c7ba065335..bf0b0a86d023 100644 --- a/libbeat/outputs/kafka/config.go +++ b/libbeat/outputs/kafka/config.go @@ -305,11 +305,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, )