Hi Kathees, Seems like issue when configuring/starting server.
Can you help on this matter pls? On Thu, Sep 3, 2015 at 9:48 PM, Nayomi Dayarathne <[email protected]> wrote: > 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 > > -- Best Regards, Malaka Silva Senior Tech Lead M: +94 777 219 791 Tel : 94 11 214 5345 Fax :94 11 2145300 Skype : malaka.sampath.silva LinkedIn : http://www.linkedin.com/pub/malaka-silva/6/33/77 Blog : http://mrmalakasilva.blogspot.com/ WSO2, Inc. lean . enterprise . middleware http://www.wso2.com/ http://www.wso2.com/about/team/malaka-silva/ <http://wso2.com/about/team/malaka-silva/> Save a tree -Conserve nature & Save the world for your future. Print this email only if it is absolutely necessary.
_______________________________________________ Dev mailing list [email protected] http://wso2.org/cgi-bin/mailman/listinfo/dev
