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
