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. >
