please checkout the kafka integration test under integration.kafka.api package.
On Thu, Jun 4, 2015 at 8:31 AM, Vadim Keylis <[email protected]> wrote: > We are using kafka 0.8.1.1. I am writing java consumer that will use simple > api and keep offset internally. I would like to write automated tests, that > will use embedded into java junit kafka and zookeeper to test against. > Would you guys point to any working examples. > > Thanks so much in advance, > Vadim >
