I creatively reused this code to have embedded kafka and zookeeper working for test purposes:
https://github.com/apache/samza/blob/master/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala Works like a charm! MJ On 20 April 2015 at 10:29, sunil kalva <sambarc...@gmail.com> wrote: > Warren > I am looking into "https://gist.github.com/asmaier/6465468";, its not > compiling in my box, i am using kafak-0.8.2.1, and i am using testng java > code for writing my test cases. > > On Mon, Apr 20, 2015 at 11:33 AM, Warren Henning <warren.henn...@gmail.com> > wrote: > >> Also consider with whether you could get away with mocking out the Kafka >> broker, depending on what/how you like to test. >> >> On Sun, Apr 19, 2015 at 10:47 PM, sunil kalva <kalva.ka...@gmail.com> >> wrote: >> >> > Hi >> > Any one tried running zookeeper and kafka locally , which can be useful >> for >> > automating the test cases for API built on kafka ? >> > >> > SunilKalva >> > >> > > > > -- > SunilKalva -- Twitter: @mjaskowski
