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 following error
>
> error when handling request
>
> Name:LeaderAndIsrRequest;Version:0;Controller:0;ControllerEpoch:1;CorrelationId:9;ClientId:id_0-host_localhost-port_9000;Leaders:id:0,host:localhost,port:9000;PartitionState:(netopic,0)
> ->
>
> (LeaderAndIsrInfo:(Leader:0,ISR:0,1,LeaderEpoch:0,ControllerEpoch:1),ReplicationFactor:2),AllReplicas:0,1)
> (kafka.server.KafkaApis:103)
>
> It creates topics and i can check for existence
>
> Output from my program
> All topics Map(new-topic -> {})
> topic exists true
>
> here's how i'm creating the zookeeper client and topic
>
> zkClient = new ZkClient(zookeeper.connectString(),
> zkSessionTimeout,zkConnectionTimeout, ZKStringSerializer$.MODULE$ );
>
> AdminUtils.createTopic(zkClient, topic, 1,
> 2,AdminUtils.createTopic$default$5());
>
> kafka version
>
> <groupId>org.apache.kafka</groupId>
> <artifactId>kafka_2.9.2</artifactId>
> <version>0.8.1.1</version>
>
> Let me know if anyone has faced this issue and any resolution for the same.
>
> Regards,
> Sathya
>
