Can you elaborate on this. "Is broker able to connect to ZK properly ? May be this can be checked via ZK CLI tools to check if the broker registrations happen properly as soon as you start Kafka broker" On Mar 26, 2016 8:18 AM, "Muthukumaran K" <muthukumara...@ericsson.com> wrote:
> Hi Bhargo, > > I ran into similar issues mainly due to firewall restrictions in my setup > with remote VM running broker and ZK. In my little experience, few things > to check concretely before running our own clients to see if the changes of > server.properties is properly done > > > - Is your ZK running on the same system as one of broker instance ? > > - Is broker able to connect to ZK properly ? May be this can be > checked via ZK CLI tools to check if the broker registrations happen > properly as soon as you start Kafka broker > > - Is your topic created and accessible via ‘sudo > ./bin/kafka-topics.sh’ command remotely with –describe flag? > > - Was console-producer and console-consumer run from a remote > machine to check if they really work with the remote broker config changes > you have done ? > > This can help troubleshooting where the issue lies. > > Regards > Muthu > > > From: amar dev [mailto:amar_9...@yahoo.com.INVALID] > Sent: Saturday, March 26, 2016 8:08 PM > To: users@kafka.apache.org > Subject: Error while publishing messages > > Hi Team!! > > I am working on a POC for my project, where I want to replace RabbitMQ > with Kafka > I am using the 0.9.0.1 version of kafka on my Ubuntu 15.10 version. > I have been able to setup the basic setup, where from the console producer > I can send messages and from the console consumer, I can consume them as > well. > But, when I try to create a java program to send the messages to the same > topic, I get an exception stacktrace in my IDE console and my console > consumer shows the same message 4 times. > > The exception that I get is the following:- > Exception in thread "main" kafka.common.FailedToSendMessageException: > Failed to send messages after 3 tries. > at > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:91) > at kafka.producer.Producer.send(Producer.scala:77) > at kafka.javaapi.producer.Producer.send(Producer.scala:33) > at com.bhargo.main.MainClass.publishMessage(MainClass.java:47) > at com.bhargo.main.MainClass.main(MainClass.java:58) > > I am not sure what the issue is, I have made sure that server.properties > file that is used to startup my broker has the correct configurations:- > zookeeper.connect=crazybox:2181 > advertised.port=9092 > advertised.host.name=crazybox > host.name=crazybox > port=9092 > > On running the command hostname , I get the result as "crazybox" and > hostname -i, gives me 127.0.0.1 > I am attaching the code for your reference. > Please have a look once. > > Any help here is much appreciated. > > Thanks, > Bhargo >
