We have a nagios check that runs the command line lag check and determines if any partition has a lag greater then X. Its about a 2 hour solutiontocode up right but worth every penny.
On Fri, Mar 28, 2014 at 7:45 PM, Otis Gospodnetic < otis.gospodne...@gmail.com> wrote: > Hi Harsh, > > Are you trying to monitor lag? > SPM for Kafka has this in one of the graphs. We get this data from JMX. > There are other tools that were mentioned here a couple of weeks > ago....sorry, can't recall their names now, check > http://search-hadoop.com/kafka , that get this info from ZK and graph it. > > Otis > -- > Performance Monitoring * Log Analytics * Search Analytics > Solr & Elasticsearch Support * http://sematext.com/ > > > On Fri, Mar 28, 2014 at 4:43 PM, Harshvardhan Chauhan <ha...@gumgum.com > >wrote: > > > I am aware of that but I should have put my question more accurately. > > > > I want to automate monitoring consumer offset and lag and wanted to know > if > > there is a Java API for that. > > The ConsumerOffsetChecker has a main method and prints the information on > > console, I want to capture the data and push it to a monitoring server > in a > > cleaner way other > > than capturing ConsumerOffsetChecker console output. > > > > Regards, > > Harsh > > > > > > On Fri, Mar 28, 2014 at 1:41 PM, Seshadri, Balaji > > <balaji.sesha...@dish.com>wrote: > > > > > This is Scala API should be possible to call it from Groovy. > > > > > > -----Original Message----- > > > From: Seshadri, Balaji [mailto:balaji.sesha...@dish.com] > > > Sent: Friday, March 28, 2014 1:57 PM > > > To: 'users@kafka.apache.org' > > > Subject: RE: Java API to monitor Consumer Offset and Lag > > > > > > kafka.tools.ConsumerOffsetChecker > > > > > > -----Original Message----- > > > From: Harshvardhan Chauhan [mailto:ha...@gumgum.com] > > > Sent: Friday, March 28, 2014 12:54 PM > > > To: users@kafka.apache.org > > > Subject: Java API to monitor Consumer Offset and Lag > > > > > > Hi, > > > > > > I am trying to write a groovy script to get consumer offsets and lag > for > > > our kafka cluster. > > > Is there a Java API to get this information ? > > > > > > Thanks & regards, > > > -- > > > *Harshvardhan Chauhan* | Big Data Engineer > > > *GumGum* <http://www.gumgum.com/> | *Ads that stick* > > > 310-260-9666 | ha...@gumgum.com > > > > > > > > > > > -- > > *Harshvardhan Chauhan* | Big Data Engineer > > *GumGum* <http://www.gumgum.com/> | *Ads that stick* > > 310-260-9666 | ha...@gumgum.com > > >
