Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # user - Re: WebMethods consumer for Kafka.


Copy link to this message
-
Re: WebMethods consumer for Kafka.
Neha Narkhede 2013-05-17, 04:00
It seems that the zookeeper host string is null or empty. Can you paste the
code you used to instantiate the consumer?

Thanks,
Neha
On May 16, 2013 12:45 PM, "Seshadri, Balaji" <[EMAIL PROTECTED]>
wrote:

> 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,