RE: Question about ConsoleConsumer

2014-07-16 Thread Shao, Saisai
Hi Joe, Thanks for your answer, seems I know what's its purpose. Thanks a lot. Jerry -Original Message- From: Joe Stein [mailto:joe.st...@stealth.ly] Sent: Thursday, July 17, 2014 10:15 AM To: d...@kafka.apache.org Cc: users@kafka.apache.org Subject: Re: Question about ConsoleCon

Re: Question about ConsoleConsumer

2014-07-16 Thread Joe Stein
auto.offset.reset is only when there is not an already established offset to consume from or an offset that no longer exists (and is invalid) in the case of truncated logs or compaction). You can force this behavior by deleting the znode /*** Joe Stein Fo