Re: Getting the latest message always from Kafka

2013-05-17 Thread Neha Narkhede
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

Getting the latest message always from Kafka

2013-05-17 Thread Kishore V. Kopalle
Hi Neha, I am sorry about the design of this program, but what I am trying to do is to expose API to read and write from Kafka. I have some unit test cases as given below. The problem is that the first test case passes but the second test case fails saying that : org.junit.ComparisonFailure: expec