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, 2014 at 8:25 AM, Yonghui Zhao <zhaoyong...@gmail.com> wrote: > Hi， > > In kafka 0.8, does high level consumer support setting offset? > > Our service reads kafka data but won't flush the data immediately, so if > restarted the data in memory will be lost. We want to reset kafka consumer > offset to an old offset. > > If the consumer group has only 1 machine, we can record all partition > offset for our topic in disk. Does the high level consumer support > setting offset in zk to the recorded offset? > -- -- Guozhang
