Hi, I would like to embed a Kafka broker in my Java program, for testing purposes.
The idea is being capable of running a Junit test that starts a local kafka broker, and then perform tests on some custom producers and consumers. After searching around, I've found some pieces of code but none of them seem to work with Kafka 0.8 API. Does anyone know about any guide/best practice or code example I could use for this purpose? Thanks in advance!
