What Guozhang said is essentially what I was saying. I realized my code is not directly applicable to your problem as it only checks the partition offsets and not whether a consumer is actually consuming the partitions.
On Mar 20, 2014, at 5:38 PM, Todd Gatts <[EMAIL PROTECTED]> wrote:

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