WebMethods consumer for Kafka.

[Seshadri, Balaji]

Hi,

I'm trying to write webMethods consumer for Kafka and I get the following error 
when I try to integrate.

java.lang.NullPointerException
                at org.apache.zookeeper.ClientCnxn.<init>(ClientCnxn.java:360)
                at org.apache.zookeeper.ClientCnxn.<init>(ClientCnxn.java:331)
                at org.apache.zookeeper.ZooKeeper.<init>(ZooKeeper.java:377)
                at 
org.I0Itec.zkclient.ZkConnection.connect(ZkConnection.java:64)
                at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java:872)
                at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:98)
                at org.I0Itec.zkclient.ZkClient.<init>(ZkClient.java:84)
                at 
kafka.consumer.ZookeeperConsumerConnector.connectZk(ZookeeperConsumerConnector.scala:154)
                at 
kafka.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:112)
                at 
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:64)
                at 
kafka.javaapi.consumer.ZookeeperConsumerConnector.<init>(ZookeeperConsumerConnector.scala:66)
                at 
kafka.consumer.Consumer$.createJavaConsumerConnector(ConsumerConnector.scala:100)
                at 
kafka.consumer.Consumer.createJavaConsumerConnector(ConsumerConnector.scala)
                at 
com.dish.des.kafka.KafkaTopicConsumer.<init>(KafkaTopicConsumer.java:44)
                at MyConsumer.utils.getMessages(utils.java:58)
                at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
                at 
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
                at 
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
                at java.lang.reflect.Method.invoke(Method.java:597)
                at 
com.wm.app.b2b.server.JavaService.baseInvoke(JavaService.java:439)
                at 
com.wm.app.b2b.server.invoke.InvokeManager.process(InvokeManager.java:643)
                at 
com.wm.app.b2b.server.util.tspace.ReservationProcessor.process(ReservationProcessor.java:46)
                at 
com.wm.app.b2b.server.invoke.StatisticsProcessor.process(StatisticsProcessor.java:44)
                at 
com.wm.app.b2b.server.invoke.ServiceCompletionImpl.process(ServiceCompletionImpl.java:243)
                at 
com.wm.app.b2b.server.invoke.ValidateProcessor.process(ValidateProcessor.java:51)
                at 
com.wm.app.b2b.server.invoke.PipelineProcessor.process(PipelineProcessor.java:171)
                at com.wm.app.b2b.server.ACLManager.process(ACLManager.java:276)
                at 
com.wm.app.b2b.server.invoke.DispatchProcessor.process(DispatchProcessor.java:30)
                at 
com.wm.app.b2b.server.AuditLogManager.process(AuditLogManager.java:363)
                at 
com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:547)
                at 
com.wm.app.b2b.server.invoke.InvokeManager.invoke(InvokeManager.java:386)
                at 
com.wm.app.b2b.server.ServiceManager.invoke(ServiceManager.java:234)
                at 
com.wm.app.b2b.server.comm.DefaultServerRequestHandler.handleMessage(DefaultServerRequestHandler.java:119)
                at 
com.wm.app.b2b.server.HTTPMessageHandler.process(HTTPMessageHandler.java:160)
                at 
com.wm.app.b2b.server.HTTPDispatch.handleRequest(HTTPDispatch.java:181)
                at com.wm.app.b2b.server.Dispatch.run(Dispatch.java:354)
                at com.wm.util.pool.PooledThread.run(PooledThread.java:131)
                at java.lang.Thread.run(Thread.java:662)

Please let me know fix for this.

Thanks,

Balaji