Re: Issue with unit testing Kafka on 0.8.1.1 and scala 2.9.2

2014-07-31 Thread Sathyanarayanan Nagarajan
I wrote my java code based on kafka unit testing example code. Have you got it working on a java code? Regards, Sathya On Wed, Jul 30, 2014 at 9:07 PM, Jun Rao wrote: > Perhaps you can follow some examples in Kafka unit test? > > Thanks, > > Jun > > > On Tue, Jul 29, 2014 at 7:32 PM, Sathyana

Re: Issue with unit testing Kafka on 0.8.1.1 and scala 2.9.2

2014-07-30 Thread Jun Rao
Perhaps you can follow some examples in Kafka unit test? Thanks, Jun On Tue, Jul 29, 2014 at 7:32 PM, Sathyanarayanan Nagarajan < sathy...@gmail.com> wrote: > Hi, > > i have been trying to run the kafka server using TestUtils.for my unit > tests, while the topic gets created, i'm getting the

Issue with unit testing Kafka on 0.8.1.1 and scala 2.9.2

2014-07-29 Thread Sathyanarayanan Nagarajan
Hi, i have been trying to run the kafka server using TestUtils.for my unit tests, while the topic gets created, i'm getting the following error error when handling request Name:LeaderAndIsrRequest;Version:0;Controller:0;ControllerEpoch:1;CorrelationId:9;ClientId:id_0-host_localhost-port_9000;Le