A utility that updates the offset of broker partitions in ZK.
This utility expects 2 input files as arguments:
consumer properties file
2. a file contains partition offsets data such as:
(This output data file can be obtained by running kafka.tools.ExportZkOffsets)
To print debug message, add the following line to log4j.properties:
log4j.logger.kafka.tools.ImportZkOffsets$=DEBUG
(for eclipse debugging, copy log4j.properties to the binary directory in "core" such as core/bin)
A utility that updates the offset of broker partitions in ZK.
This utility expects 2 input files as arguments:
/consumers/group1/offsets/topic1/3-0:285038193 /consumers/group1/offsets/topic1/1-0:286894308
To print debug message, add the following line to log4j.properties: log4j.logger.kafka.tools.ImportZkOffsets$=DEBUG (for eclipse debugging, copy log4j.properties to the binary directory in "core" such as core/bin)