can you check that you can connect on port 9092 from producer to broker? (check with telnet or something similar) ping may succeed when a port is blocked.
On Wed, Oct 8, 2014 at 9:40 AM, ravi singh <[email protected]> wrote: > Even though I am able to ping to the broker machine from my producer > machine , the producer is throwing below expcetion while connecting to > broker. > I wanted to increase time out for producer but couldnt find any parameter > for that in kafka 8. > Any idea whats wrong here? > > [2014-10-08 09:29:47,762] ERROR Producer connection to 10.22.44.555:9092 > unsuccessful (kafka.producer.SyncProducer) > java.net.ConnectException: Connection timed out > at sun.nio.ch.Net.connect0(Native Method) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) > at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) > at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) > at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) > at > kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) > at kafka.producer.SyncProducer.send(SyncProducer.scala:112) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53) > at > kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82) > at > kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67) > at kafka.utils.Utils$.swallow(Utils.scala:167) > at kafka.utils.Logging$class.swallowError(Logging.scala:106) > at kafka.utils.Utils$.swallowError(Utils.scala:46) > at > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67) > at > kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) > at > kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:87) > at > kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:67) > at scala.collection.immutable.Stream.foreach(Stream.scala:254) > at > kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66) > at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) > [2014-10-08 09:29:47,766] WARN Fetching topic metadata with correlation id > 0 for topics [Set(test_new)] from broker [id:0,host:10.22.33.444,port:9092] > failed (kafka.client.ClientUtils$) > java.net.ConnectException: Connection timed out > at sun.nio.ch.Net.connect0(Native Method) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.Net.connect(Unknown Source) > at sun.nio.ch.SocketChannelImpl.connect(Unknown Source) > at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57) > at kafka.producer.SyncProducer.connect(SyncProducer.scala:141) > at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156) > at > kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68) > at kafka.producer.SyncProducer.send(SyncProducer.scala:112) > at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53) > at > kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82) > at > kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:67) > at kafka.utils.Utils$.swallow(Utils.scala:167) > at kafka.utils.Logging$class.swallowError(Logging.scala:106) > at kafka.utils.Utils$.swallowError(Utils.scala:46) > at > kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:67) > at > kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:104) > at > kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:87) > at > kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:67) > at scala.collection.immutable.Stream.foreach(Stream.scala:254) > at > kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:66) > at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:44) > > -- > *Regards,* > *Ravi*
