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 <[EMAIL PROTECTED]>wrote: *Harshvardhan Chauhan* | Big Data Engineer *GumGum* <http://www.gumgum.com/> | *Ads that stick* 310-260-9666 | [EMAIL PROTECTED]
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 <[EMAIL PROTECTED]>wrote:
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 < [EMAIL PROTECTED]> wrote: