Thanks for reply, Guozhang. I got 'Missing required argument "[zookeeper]"' after running that.
Yifan On Mon, Jan 25, 2016 at 6:05 PM, Guozhang Wang <wangg...@gmail.com> wrote: > 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 > -- Yifan
