I have banged my head for nearly 3 hours trying to find out why my producer code did not enqueue the message. And later found a very simple issue.
I dont want anyone else to waste their time in this and hence this email.
1) Broker is in a physical Linux box. The broker was registered using the "hostname"
[2014-02-23 01:58:09,760] INFO Registered broker 0 at path /brokers/ids/0 with address myhost name:9092. (kafka.utils.ZkUtils$)
2) The producer code was in windows machine. I was setting the property in the producer code as : this.props.put("metadata.broker.list", "17x.xx.xx.xx:9092"); So the message was not enqueue into Kafka.
Jun On Sun, Feb 23, 2014 at 4:52 AM, Krishna Raj <[EMAIL PROTECTED]>wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation projects and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext