+ 1!

A call through the Consumer Group, queuedMessageCount(topic,
partitionNumber), could query zookeeper (and add the local fetched queue) to
return this interesting piece of information.  That is if we cannot already
do this :)

Thanks,
rob

to

 
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