Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka >> mail # user >> Re: Kafka 0.8.0-beta1 with Spark Streaming


Copy link to this message
-
Re: Kafka 0.8.0-beta1 with Spark Streaming
Are you able to telnet from the producer machine to the broker?

Thanks,
Neha
On Oct 22, 2013 7:13 AM, "Arindam Paul" <[EMAIL PROTECTED]> wrote:

> 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.
>