I have built Spark 0.8.0 with Kafka 0.8.0-beta1 and when I am running the producer code, I am getting the following error. I have checked that I am using the latest property attributes in my code, like, metadata.broker.list (props.put("metadata.broker.list", brokers)) Please help me understand what's wrong here.
2013-10-22 09:59:14 INFO ClientUtils$:67 - Fetching metadata from broker id:0,host:x.x.x.x,port:9092 with correlation id 0 for 1 topic(s) Set(topic-test) 2013-10-22 09:59:14 INFO SyncProducer:67 - Connected to x.x.x.x:9092 for producing 2013-10-22 09:59:14 INFO SyncProducer:67 - Disconnecting from x.x.x.x:9092 2013-10-22 10:00:18 ERROR SyncProducer:102 - Producer connection to x.x.x.x:9092 unsuccessful java.net.ConnectException: Connection timed out 2013-10-22 10:00:18 WARN DefaultEventHandler:88 - Failed to send producer request with correlation id 4 to broker 1 with data for partitions [topic-test,0] java.net.ConnectException: Connection timed out at sun.nio.ch.Net.connect0(Native Method) Thanks.
Thanks Neha. That was the issue. Configuring the right access policies in AWS solved the problem. Thanks again.
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project 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