For every unit test, you want your server and consumer to start fresh. In
your unit test, you maintain state in the KafkaManager across unit tests so
your tests don't work as expected. Try moving KafkaManager to the setup
method. Currently, the 2nd test is consuming the message produced by the
1st test

On Fri, May 17, 2013 at 7:32 AM, Kishore V. Kopalle <
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