Hi all, The solution that kathees gave was solved the problem partially. But, not only we have to change the zookeeper.connect value to IP address of kafka IE, but also we have to change the host.name property in server.properties file in kafka server as below.
Uncomment the host.name in server.properties file and give the IP address in kafka inbound endpoint, instead of the localhost. Therefore, in a cluster scenario, we have to change the following properties in server.properties file in kafka_home/config location, before we start the kafka server. 1. host.name =IP address of the kafka inbound endpoint we give in the zookeeper.connect parameter. 2. zookeeper.connect =IP address of the kafka inbound endpoint we give in the zookeeper.connect parameter. Thanks a lot for the help kathees and the problem has solved. Nayomi Dayarathne *Software Engineer-QA* Mobile : +94 (0) 775246619 <+94+(0)+775246619> *nay...@wso2.com <nay...@wso2.com>* On Fri, Sep 4, 2015 at 11:09 AM, Kathees Rajendram <kath...@wso2.com> wrote: > Hi Niyomi, > > Can you change to the IP address instead of localhost in server.properties > file as you use the IP address in the Kafka inbound. > > zookeeper.connect=localhost:2181 > > Thanks, > Kathees. > > On Fri, Sep 4, 2015 at 10:31 AM, Kathees Rajendram <kath...@wso2.com> > wrote: > >> Hi Malaka. >> >> I will have a look. >> >> Thanks, >> Kathees >> >> On Fri, Sep 4, 2015 at 9:36 AM, Malaka Silva <mal...@wso2.com> wrote: >> >>> 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 <nay...@wso2.com> >>> 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> >>>> >>>> *nay...@wso2.com <nay...@wso2.com>* >>>> >>>> On Thu, Sep 3, 2015 at 9:32 PM, Chanaka Fernando <chana...@wso2.com> >>>> wrote: >>>> >>>>> Viraj is looking into this. >>>>> >>>>> On Thu, Sep 3, 2015 at 9:24 PM, Nayomi Dayarathne <nay...@wso2.com> >>>>> 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> >>>>>> >>>>>> *nay...@wso2.com <nay...@wso2.com>* >>>>>> >>>>> >>>>> >>>>> >>>>> -- >>>>> -- >>>>> 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 >>>> Dev@wso2.org >>>> 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. >>> >> >> >> >> -- >> Kathees >> Software Engineer, >> email: kath...@wso2.com >> mobile: +94772596173 >> > > > > -- > Kathees > Software Engineer, > email: kath...@wso2.com > mobile: +94772596173 >
_______________________________________________ Dev mailing list Dev@wso2.org http://wso2.org/cgi-bin/mailman/listinfo/dev
