Hi Vamsi, The ConsumerOffsetChecker.scala or kafka-consumer-offset-checker.sh still works. You can use them to check the offsets. If you need to check the offsets programmatically, you can send OffsetsFetcheRequest to broker using simple consumer. You may refer the ConsumerOffsetChecker.scala to see how to find correct broker where corresponding offset manager resides.
Jiangjie (Becket) Qin On 3/19/15, 11:54 PM, "Achanta Vamsi Subhash" <achanta.va...@flipkart.com> wrote: >Hi, > >We are using 0.8.2.1 currently. > >- How to get the consumer offsets from the offsets topic? >​- Is there any built-in function which I could use? (like in >AdminUtils.scala) >- Is it ok to start a simple consumer and read the offsets from the topic? > >​We used to read the offsets from zookeeper previously for the >HighLevelConsumers. But with the new broker this changed as we are using >Kafka topic for offsets.​ > >-- >Regards >Vamsi Subhash
