Zk host:port string
2. group name (all groups implied if omitted)
3. output filename
To print debug message, add the following line to log4j.properties:
log4j.logger.kafka.tools.ExportZkOffsets$=DEBUG
(for eclipse debugging, copy log4j.properties to the binary directory in "core" such as core/bin)
A utility that retrieve the offset of broker partitions in ZK and prints to an output file in the following format:
/consumers/group1/offsets/topic1/1-0:286894308 /consumers/group1/offsets/topic1/2-0:284803985
This utility expects 3 arguments:
To print debug message, add the following line to log4j.properties: log4j.logger.kafka.tools.ExportZkOffsets$=DEBUG (for eclipse debugging, copy log4j.properties to the binary directory in "core" such as core/bin)