Re: To find the Lag of consumer offset using kafka client library

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, wrote: > Thanks for your suggestion, I had previously read about Yahoo Kafka monitor > as s

Re: To find the Lag of consumer offset using kafka client library

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-co

Re: To find the Lag of consumer offset using kafka client library

Hi Gourab, Check this out: https://github.com/linkedin/Burrow Regards Jan > On 29 Sep 2016, at 15:47, Gourab Chowdhury wrote: > > I can get the *Lag* of offsets with the following command:- > > bin/kafka-run-class.sh kafka.admin.ConsumerGroupCommand --z

To find the Lag of consumer offset using kafka client library

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 docume