One thing is that you need to make sure the consumer starts consuming from
the beginning of the topic, otherwise by default, it will start from the
latest message in the topic, from the time it starts up. Since the
consumer and producer are asynchronous, it's hard to assert that the
consumer is co
I am trying to write a junit test for working with an embedded Kafka 0.8
server where I send and receive messages just to verify my embedded server,
producer and consumer wrappers work. Order of operation in the junit looks
something like:
-Start zk. [own thread] (wait for init)
-Start Kafka [own
