Good evening. I am writing consumer that is based on SimpleConsumer. I would like to write integration/unit tests that simulate different error responses from kafka to make sure my code handles it properly. How do you guys advised to do this within my unit test? Do you have some kind of mock kafka that capable of doing this? What would be your advise?
Thanks so much, Vadim.
