You can take a look at KafkaServerTestHarness in our unit tests.
Thanks,
Jun
On Thu, Dec 12, 2013 at 3:14 AM, Javier Alba <me@fjavieralba.com> 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!
>
|