Skip to content

Commit

Permalink
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions libbeat/outputs/kafka/config.go
Original file line number Diff line number Diff line change
@@ -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,
)

0 comments on commit f392454

Please sign in to comment.