You can take a look at KafkaServerTestHarness in our unit tests. Thanks,
Jun On Thu, Dec 12, 2013 at 3:14 AM, Javier Alba <[email protected]> wrote: > 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! >
