A simple tool to calculate the lag of a given consumer group from Burrow and report it to InfluxDB.
NOTE: While this code seems stable, it has not been extensively tested. If you have any problems please open an issue (or better yet, a pull request).
git clone https://github.com/splee/burrow.git- Create a package jar for metrics-influxdb and place in
<project_root>/lib/ cd burrow && sbt assembly- Update configuration (example:
burrow/conf/application.conf.example) java -cp target/scala-2.11/burrower-0.1.jar:conf/ com.github.splee.burrower.OffsetMonitor