Thanks, Jun. I checked ImportZkOffsets. It is not very handy and cannot automate all steps for purging purpose.
Regards, Libo -----Original Message----- From: Jun Rao [mailto:jun...@gmail.com] Sent: Tuesday, January 14, 2014 11:43 PM To: users@kafka.apache.org Subject: Re: purging a topic 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 > >
