Currently, the only way to rewind the high level consumer to a different
offset is to first shutdown all instances of the consumer, update zookeeper
with the desired offsets and then restart the consumer. We are addressing
this in the new consumer APIs for Kafka 0.9. If you can review the proposal
Hello Yonghui,
In 0.8 high level consumer does not support setting offsets directly.
However, you can use this tool to manually set the offset in ZK before you
re-start the consumer to change the starting offset:
bin/kafka-run-class.sh kafka.tools.UpdateOffsetsInZK
Guozhang
On Thu, Feb 27, 201
