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
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