Created 09-25-2015 06:49 PM
I am using hortonwork Sandbox for kafka server trying to connect kafka from eclipse with java code . Use this configuration to connect to producer to send the message
metadata.broker.list=sandbox.hortonworks.com:45000 serializer.class=kafka.serializer.DefaultEncoder zk.connect=sandbox.hortonworks.com:2181 request.required.acks=0 producer.type=sync
where sandbox.hortonworks.com is sandboxname to whom i connect
in kafka server.properties I changed this configuration
host.name=sandbox.hortonworks.com advertised.host.name=System IP(on which my eclipse is running) advertised.port=45000
did the port forwarding also ,
I am able to connect to kafka server from eclipse but while sending the message get the exception Exception"Failed to send messages after 3 tries."
Created 09-29-2015 12:28 AM
Kafka installed by ambari uses host.name=FQDN of the host. This causes kafka to bind on hostname only. Did you try adding sandbox.hortonworks.com along with ip to /etc/hosts on your desktop.
Created 09-25-2015 07:05 PM
I don't see where you specified the topic to which you want to send your message. Ensure you are setting the following Kafka property and that the topic has been created in Kafka. Other than that, everything else looks good.
kafka.topic=yourTopicName
Created 09-29-2015 12:28 AM
Kafka installed by ambari uses host.name=FQDN of the host. This causes kafka to bind on hostname only. Did you try adding sandbox.hortonworks.com along with ip to /etc/hosts on your desktop.