Apache Kafka
Monitoring Commands
Metrics & monitoring
3 commands
Commands
Show consumer lag
$ kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group <group>
Display consumer group lag and offsets.
Reset offsets to earliest
$ kafka-consumer-groups.sh --bootstrap-server localhost:9092 --reset-offsets --group <group> --topic <topic> --to-earliest --execute
Reset consumer group offsets to beginning.
Check broker disk usage
$ kafka-log-dirs.sh --bootstrap-server localhost:9092 --describe --broker-list 0,1,2
Show disk usage per broker and topic.