This is something we do routinely.   We wrap the KafkaServer from java, it
works pretty well.   You can use the KafkaServerStartable class, or the
KafkaServer class directly (in which case, you might need to do what we did
as described in:
On Thu, Dec 12, 2013 at 8:07 AM, Jun Rao <[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