> From: aravindan.ramachand...@gmail.com
> Date: Wed, 2 Mar 2016 12:28:41 -0800
> Subject: producer SSL issue - fails with ssl.trustore location/password is
> not valid
> To: users@kafka.apache.org
>
> INFO Registered broker 10 at path /brokers/ids/10 with addresses: PLAINTEXT
> -> EndPoint(kafka-ap-server101.com,9094,PLAINTEXT),SSL -> EndPoint(
> kafka-ap-server101.com,9095,SSL) (kafka.utils.ZkUtils)
>
> -bash-4.1$ bin/kafka-console-producer.sh --broker-list
> kafka-ap-server101.com:9095 --topic topic123 --producer.config
> config/producer.properties --security-protocol SSL
> [2016-03-02 20:08:11,205] WARN Property ssl.keystore.location is not valid
> (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,205] WARN Property ssl.enabled.protocols is not valid
> (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,205] WARN Property ssl.key.password is not valid
> (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,206] WARN Property ssl.keystore.password is not valid
> (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,206] WARN Property ssl.keystore.type is not valid
> (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,206] WARN Property ssl.truststore.location is not
> valid (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,206] WARN Property ssl.truststore.password is not
> valid (kafka.utils.VerifiableProperties)
> [2016-03-02 20:08:11,206] WARN Property ssl.truststore.type is not valid
> (kafka.utils.VerifiableProperties)
MG>apparently you have this property set: ssl.want.client.auth=required
MG>nobody from this group has those details as each security configuration is
different
MG>when and if your security admin can provide those details here we could help
you reconfigure security details for kafka producer
> [2016-03-02 20:08:28,490] WARN Fetching topic metadata with correlation id
> 0 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:68)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:68)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:28,493] ERROR fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed (kafka.utils.CoreUtils$)
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:68)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:68)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> Caused by: java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> ... 12 more
> [2016-03-02 20:08:28,656] WARN Fetching topic metadata with correlation id
> 1 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> at
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:188)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:152)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:151)
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> at
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:151)
> at
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:96)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:73)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:28,657] ERROR Failed to collate messages by topic,
> partition due to: fetching topic metadata for topics [Set(topic123)] from
> broker [ArrayBuffer(BrokerEndPoint(0,kafka-ap-server101.com,9095))] failed
> (kafka.producer.async.DefaultEventHandler)
> [2016-03-02 20:08:28,893] WARN Fetching topic metadata with correlation id
> 2 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:28,894] ERROR fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed (kafka.utils.CoreUtils$)
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> Caused by: java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> ... 12 more
> [2016-03-02 20:08:28,940] WARN Fetching topic metadata with correlation id
> 3 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> at
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:188)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:152)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:151)
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> at
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:151)
> at
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:96)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:73)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:28,941] ERROR Failed to collate messages by topic,
> partition due to: fetching topic metadata for topics [Set(topic123)] from
> broker [ArrayBuffer(BrokerEndPoint(0,kafka-ap-server101.com,9095))] failed
> (kafka.producer.async.DefaultEventHandler)
> [2016-03-02 20:08:29,118] WARN Fetching topic metadata with correlation id
> 4 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:29,119] ERROR fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed (kafka.utils.CoreUtils$)
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> Caused by: java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> ... 12 more
> [2016-03-02 20:08:29,162] WARN Fetching topic metadata with correlation id
> 5 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> at
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:188)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:152)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:151)
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> at
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:151)
> at
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:96)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:73)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:29,163] ERROR Failed to collate messages by topic,
> partition due to: fetching topic metadata for topics [Set(topic123)] from
> broker [ArrayBuffer(BrokerEndPoint(0,kafka-ap-server101.com,9095))] failed
> (kafka.producer.async.DefaultEventHandler)
> [2016-03-02 20:08:29,340] WARN Fetching topic metadata with correlation id
> 6 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:29,341] ERROR fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed (kafka.utils.CoreUtils$)
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> Caused by: java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> ... 12 more
> [2016-03-02 20:08:29,384] WARN Fetching topic metadata with correlation id
> 7 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.BrokerPartitionInfo.getBrokerPartitionInfo(BrokerPartitionInfo.scala:49)
> at
> kafka.producer.async.DefaultEventHandler.kafka$producer$async$DefaultEventHandler$$getPartitionListForTopic(DefaultEventHandler.scala:188)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:152)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$partitionAndCollate$1.apply(DefaultEventHandler.scala:151)
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
> at
> kafka.producer.async.DefaultEventHandler.partitionAndCollate(DefaultEventHandler.scala:151)
> at
> kafka.producer.async.DefaultEventHandler.dispatchSerializedData(DefaultEventHandler.scala:96)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:73)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:29,385] ERROR Failed to collate messages by topic,
> partition due to: fetching topic metadata for topics [Set(topic123)] from
> broker [ArrayBuffer(BrokerEndPoint(0,kafka-ap-server101.com,9095))] failed
> (kafka.producer.async.DefaultEventHandler)
> [2016-03-02 20:08:29,559] WARN Fetching topic metadata with correlation id
> 8 for topics [Set(topic123)] from broker [BrokerEndPoint(0,
> kafka-ap-server101.com,9095)] failed (kafka.client.ClientUtils$)
> java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> [2016-03-02 20:08:29,560] ERROR fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed (kafka.utils.CoreUtils$)
> kafka.common.KafkaException: fetching topic metadata for topics
> [Set(topic123)] from broker [ArrayBuffer(BrokerEndPoint(0,
> kafka-ap-server101.com,9095))] failed
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:73)
> at
> kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82)
> at
> kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:79)
> at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79)
> at kafka.utils.Logging$class.swallowError(Logging.scala:106)
> at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51)
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:79)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
> Caused by: java.io.EOFException
> at
> org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99)
> at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:140)
> at kafka.network.BlockingChannel.receive(BlockingChannel.scala:131)
> at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:79)
> at
> kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:76)
> at kafka.producer.SyncProducer.send(SyncProducer.scala:121)
> at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59)
> ... 12 more
> [2016-03-02 20:08:29,561] ERROR Failed to send requests for topics topic123
> with correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler)
> [2016-03-02 20:08:29,562] ERROR Error in handling batch of 1 events
> (kafka.producer.async.ProducerSendThread)
> kafka.common.FailedToSendMessageException: Failed to send messages after 3
> tries.
> at
> kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:91)
> at
> kafka.producer.async.ProducerSendThread.tryToHandle(ProducerSendThread.scala:105)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:88)
> at
> kafka.producer.async.ProducerSendThread$$anonfun$processEvents$3.apply(ProducerSendThread.scala:68)
> at scala.collection.immutable.Stream.foreach(Stream.scala:547)
> at
> kafka.producer.async.ProducerSendThread.processEvents(ProducerSendThread.scala:67)
> at kafka.producer.async.ProducerSendThread.run(ProducerSendThread.scala:45)
>
>
>
> Thanks & Regards,
> Aravindan Ramachandran
