kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Arindam Paul <ap...@sapient.com>
Subject Kafka 0.8.0-beta1 with Spark Streaming
Date Tue, 22 Oct 2013 11:58:09 GMT
Hi,

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.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message