Hi all, This issue is not related to the jira[1] i have reported.
According to my understanding this is something related to kafka server. Therefore i assumed this issue is not related to kafka inbound endpoint. [1]https://wso2.org/jira/browse/ESBJAVA-4153 Nayomi Dayarathne *Software Engineer-QA* Mobile : +94 (0) 775246619 <+94+(0)+775246619> *[email protected] <[email protected]>* On Thu, Sep 3, 2015 at 9:32 PM, Chanaka Fernando <[email protected]> wrote: > Viraj is looking into this. > > On Thu, Sep 3, 2015 at 9:24 PM, Nayomi Dayarathne <[email protected]> wrote: > >> Hi ESB team, >> >> I tested the kafka inbound endpoint in a esb cluster where there is one >> manager and two worker nodes. >> >> Below are the steps i did when testing the kafka inbound endpoint. >> >> 1. Start the zookeeper >> 2.Start the kafka server >> >> Zookeeper and kafka server started in my local machine. >> >> 3.Create a kafka inbound endpoint in cluster >> >> it gets deployed in all three nodes. >> >> 4.Then create a topic in kafka broker. >> >> >> then, in one of the worker nodes i get the following error, >> >> ERROR {kafka.producer.SyncProducer} - Producer connection to >> localhost:9092 unsuccessful {kafka.producer.SyncProducer} >> java.net.ConnectException: Connection refused >> at sun.nio.ch.Net.connect0(Native Method) >> at sun.nio.ch.Net.connect(Net.java:435) >> at sun.nio.ch.Net.connect(Net.java:427) >> at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:643) >> at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) >> at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) >> at >> kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) >> at >> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) >> at kafka.producer.SyncProducer.send(SyncProducer.scala:112) >> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53) >> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:88) >> at >> kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66) >> at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51) >> >> >> >> the above message is throwing continuously by the worker node. >> >> I assume this issue is related to some configurations of kafka server. >> >> *Any ideas of solving this issue ?* >> >> >> >> >> >> Nayomi Dayarathne >> >> *Software Engineer-QA* >> Mobile : +94 (0) 775246619 <+94+(0)+775246619> >> >> *[email protected] <[email protected]>* >> > > > > -- > -- > Chanaka Fernando > Senior Technical Lead > WSO2, Inc.; http://wso2.com > lean.enterprise.middleware > > mobile: +94 773337238 > Blog : http://soatutorials.blogspot.com > LinkedIn:http://www.linkedin.com/pub/chanaka-fernando/19/a20/5b0 > Twitter:https://twitter.com/chanakaudaya > Wordpress:http://chanakaudaya.wordpress.com > > > >
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
