This code is for monitoring Kafka offsets What it looks like? You can modify it anyway you want in Grafana, here is just my first version for demo.
- Kafka 0.10.x
- Java 8
- InfluxDB
mvn clean package
Modify the "application.conf", at least, the below parts need to be modified.
- kafka.zkAddr, the Zookeeper address
- kafka.db.influx.url, the InfluxDB address
Run the main class "app.KafkaInsight" anyway you want. It is single point for now and will be suffering from single point failure. HA is part of the plan.
For the other doc of the code, please refer to Wiki