kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jason Rosenberg <...@squareup.com>
Subject Re: Embedding a Kafka 0.8 broker for testing
Date Thu, 12 Dec 2013 18:11:24 GMT
This is something we do routinely.   We wrap the KafkaServer from java, it
works pretty well.   You can use the KafkaServerStartable class, or the
KafkaServer class directly (in which case, you might need to do what we did
as described in:  https://issues.apache.org/jira/browse/KAFKA-1101)


On Thu, Dec 12, 2013 at 8:07 AM, Jun Rao <junrao@gmail.com> wrote:

> 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!
> >
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message