You can use either the MaxLag MBean (0.8):

http://kafka.apache.org/documentation.html#monitoring

Or the ConsumerOffsetChecker (0.7 or 0.8, can't seem to find a doc
reference for it):

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker ...

Dave DeMaagd | S'aite Reliability Engineering, Y'all
[EMAIL PROTECTED] | 818 262 7958

([EMAIL PROTECTED] - Wed, Dec 04, 2013 at 12:40:59PM -0800)

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB