Hi guys, I spent some of my time in order to understand how to make easier integration tests that involves Kafka. I hope that this library will help you in your project. I'm using it in another project and it looks quite useful.
I wait your comments.