kafka-statsd

Send your Kafka offset lags to StatsD.

Usage

kafka-statsd --zookeeper-addrs host1:2181,host2:2181 --statsd-addr=statsd:8125 --statsd-prefix kafka. --tags

Args

Arg	Description
--zookeeper-addrs	List of Zookeeper addresses, comma delimited. Supports Zookeeper chroots for Kafka metadata that do not reside under the root node, e.g. host1:2181,host2:2181/kafka.
--statsd-addr	StatsD address.
--statsd-prefix	StatsD prefix.
--refresh-interval	Interval to refresh offset lag, in seconds. Default is 5s.
--tags	Use tags if your StatsD client supports them (like DataDog and InfluxDB). Default is false.

StatsD metric:

With tags:

kafka_consumer_lag,topic=TOPIC,partition=PARTITION,consumer_group=CONSUMER_GROUP = N

Without tags:

topic.TOPIC.partition.PARTITION.consumer_group.CONSUMER_GROUP.lag = N

Install

Binary download:

https://github.com/travisjeffery/kafka-statsd/releases

Go get:

$ go get github.com/travisjeffery/kafka-statsd

Docker:

$ docker run -d travisjeffery/kafka-statsd --zookeeper-addrs host1:2181,host2:2181 --statsd-addr=statsd:8125 --statsd-prefix kafka.

License

MIT

---

• travisjeffery.com
• Twitter @travisjeffery
• GitHub @travisjeffery