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

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


+
Neha Narkhede 2013-05-17, 04:00
Copy link to this message
-
RE: WebMethods consumer for Kafka.
Neha Narkhede 2013-05-17, 15:39
3.3.3 has known serious bugs. You should at least use 3.3.4. I am not aware
of a JMS bridge. Contributions are welcome :)

Thanks,
Neha
On May 17, 2013 8:36 AM, "Seshadri, Balaji" <[EMAIL PROTECTED]>
wrote:

> Hi Neha,
>
> I figured out it was issue with jar dependencies,I tried to use latest
> stable version of zookeeper(3.4.5) and it broke.
>
> It working fine now with 3.3.3.
>
> I have one more question :).
>
> Do you guys have JMS bridge to Kafka,because webMethods supports only
> properitery and JMS spec so hooking up Kafka as a trigger in webMethods is
> becoming an issue.
>
> Thanks,
>
> Balaji
>
> -----Original Message-----
> From: Neha Narkhede [mailto:[EMAIL PROTECTED]]
> Sent: Thursday, May 16, 2013 10:00 PM
> To: [EMAIL PROTECTED]
> Subject: Re: WebMethods consumer for Kafka.
>
> 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)