Hi All,

For Kafka 0.8.2, I was using kafka-consumer-offset-checker.sh to get a
consumer group's offset . Now I am testing against Kafka 0.9 , but the same
tool always gave me


Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException:
KeeperErrorCode = NoNode for /consumers/


I saw "Committed offset 21 for partition ..." from debug logs and the
consumer doesn't re-consume messages after next time the app starts. That
means the Kafka broker has the offset.

Then I tried

./kafka-consumer-groups.sh --zookeeper localhost:2181 --list

but still not able to get any consumer groups from the list. Does anyone
know how to get consumer offset with Kafka 0.9?


Thanks.


-- 
Yifan

Reply via email to