Skip to content

Commit 713f5f0

Browse files
Add Kafka output metrics (#42537) (#42558)
(cherry picked from commit 2b8d554) Co-authored-by: William Easton <[email protected]>
1 parent 44a1170 commit 713f5f0

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

libbeat/outputs/kafka/config.go

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -305,11 +305,14 @@ func newSaramaConfig(log *logp.Logger, config *kafkaConfig) (*sarama.Config, err
305305
k.Version = version
306306

307307
k.Producer.Partitioner = partitioner
308+
308309
k.MetricRegistry = adapter.GetGoMetrics(
309310
monitoring.Default,
310-
"libbeat.outputs.kafka",
311-
adapter.Rename("incoming-byte-rate", "bytes_read"),
312-
adapter.Rename("outgoing-byte-rate", "bytes_write"),
311+
"libbeat.outputs",
312+
adapter.Rename("incoming-byte-rate", "read.bytes"),
313+
adapter.Rename("outgoing-byte-rate", "write.bytes"),
314+
adapter.Rename("request-latency-in-ms", "write.latency"),
315+
adapter.Rename("requests-in-flight", "kafka.requests-in-flight"),
313316
adapter.GoMetricsNilify,
314317
)
315318

0 commit comments

Comments
 (0)