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 wrote:
> Hi folks,
>
> I am writing a tool to "purge" the pending topics for a user. Assu
Hello Libo,
This should work, but I am more curious about your exact usage scenarios.
Would setting the default offset reset to largest be appropriate for you?
Guozhang
On Tue, Jan 14, 2014 at 12:38 PM, Yu, Libo wrote:
> Hi folks,
>
> I am writing a tool to "purge" the pending topics for a us
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 con
