You would need to first stop the consumer, update the offset in ZK and then restart the consumer. Also, have you looked at the tool ImportZkOffsets?
Thanks, Jun On Tue, Jan 14, 2014 at 12:38 PM, Yu, Libo <libo...@citi.com> wrote: > Hi folks, > > I am writing a tool to "purge" the pending topics for a user. Assume the > user has never > consumed this topic previously. If I create all the nodes on the path > /consumers/[myuser]/offsets/[mytopic]/[partition] and put the maximum > available offset to the node, is that enough to let the consumer ignore > the current pending > messages? > > Regards, > > Libo > >
