Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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.
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)

 
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB