Yes. kafka.admin helps. You can create an application that resembles the ConsumerGroupCommand.scala to get consumer offsets for both old and new consumers.
On Thu, 29 Sep 2016, 8:17 p.m. Gourab Chowdhury, <gourab....@gmail.com> wrote: > Thanks for your suggestion, I had previously read about Yahoo Kafka monitor > as suggested some where. > > What I actually need is function/class in kafka java libaray (if any) that > helps to find the lag and other details? Can kafka.admin help in this > matter? > > A code snippet equivalent to:- > bin/kafka-consumer-groups.sh --zookeeper localhost:2182 --describe --group > DemoConsumer > bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper > localhost:2182 --describe --group DemoConsumer > > Thanks > Gourab > > On Thu, Sep 29, 2016 at 7:19 PM, Jan Omar <jan.o...@wooga.net> wrote: > > > > > Hi Gourab, > > > > Check this out: > > > > https://github.com/linkedin/Burrow <https://github.com/linkedin/Burrow> > > > > Regards > > > > Jan > > > > > On 29 Sep 2016, at 15:47, Gourab Chowdhury <gourab....@gmail.com> > wrote: > > > > > > I can get the *Lag* of offsets with the following command:- > > > > > > bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --zookeeper > > > localhost:2182 --describe --group DemoConsumer > > > > > > I am trying to find code that uses kafka library to find the *Lag* of > > > offsets in consumer? > > > > > > Also is there any other documentation other than > > https://github.com/apache/ > > > kafka/tree/trunk/docs? I can't find much documentation of kafka. > > > > > > Thanks, > > > Gourab Chowdhury, > > > Software Engg. JunctionTV Inc. > > > > >
