In fact, what I see is that once all messages are being consumed - it starts consuming again all of them from the beginning..
On Sat, Nov 7, 2015 at 3:49 AM, Birendra Kumar Singh <[email protected]> wrote: > Can you guys please help me understand how to zk for existence of offset. > I tried this on a separate zkroot as well, but the problem still persists. > > Thanks > Birendra > > On Fri, Nov 6, 2015 at 11:08 PM, Santosh Pingale <[email protected] > > wrote: > >> To add to Stephen's answer, you might want to change your zkroot from >> /broker to something else as Kafka uses it to maintain the metadata. >> >> Nevertheless, you will need to check zk for existence of offset and not >> local directories of Kafka cluster. >> > >
