Yifan, Offset checker has been deprecated in 0.9.0 (search for "kafka-consumer-groups.sh"):
http://kafka.apache.org/documentation.html#upgrade If you are using the new consumer, then its metadata is not registered in ZK, so you should use the --bootstrap-server option instead of --zookeeper: ./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list Guozhang On Mon, Jan 25, 2016 at 5:03 PM, Yifan Ying <nafan...@gmail.com> wrote: > 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 > -- -- Guozhang
