[KAFKA-685] ConsumerOffsetChecker does not work with 0.8

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 0.8.0
• Component/s: core
• Assignee: Maxime Brugidou
• Reporter: Maxime Brugidou
• Created: 07/Jan/13 09:42
• Updated: 08/Jan/13 21:49
• Resolved: 08/Jan/13 21:49

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