Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
0.8.0
-
None
-
None
Description
The ConsumerOffsetChecker does not work anymore with 0.8, this tool is very useful when used with the MirrorMaker.
Here is a patch to make it work with some cosmetic changes:
- script-friendly formatting (one line per partition)
- offsets do not correspond to bytes anymore (so the lag is in number of messages, not GiB)
- --broker-info optional option to print the broker list at the end (like the previous version)
Example:
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group KafkaMirror --zkconnect zoo.example.org:2181
Group Topic Pid Offset logSize Lag Owner
KafkaMirror test 0 215385 215385 0 Some(KafkaMirror_broker01-1379350-71cf9117-0)
KafkaMirror test 1 683564 683564 0 Some(KafkaMirror_broker03-1379351-71cf9117-0)
KafkaMirror test2 0 176943 176943 0 Some(KafkaMirror_broker05-1379353-71cf91