That works, thanks. Yifan
On Mon, Jan 25, 2016 at 7:27 PM, Guozhang Wang <wangg...@gmail.com> wrote: > I forgot to mention you need to add "--new-consumer" as well. > > Guozhang > > On Mon, Jan 25, 2016 at 7:11 PM, Yifan Ying <nafan...@gmail.com> wrote: > > > 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 > > > > > > -- > -- Guozhang > -- Yifan
