It can also be used to massively collect lag and rates statistics (in json) via your orchestration tooling of choice.

CLI app to monitor real-time consumption and production rates on kafka broker.

Shows:

- A brief with topic and partitions lists and consumer group statuses, - Rate of events written to topics - Rate of events consumed by consumer groups, per topic - LAG per consumer group and topic - ETA for each consumer group to consume the remaining topic events

Supports:

- Multiple topics/consumer group - Showing only troublesome groups, useful if you have hundreds - Exporting status in json for mass health surveillance of remote hosts