Created
January 29, 2016 13:16
-
-
Save vishalsuvagia/d0746968d8940b8edb5d to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [2016-01-29 09:24:17,945] ERROR The TGT cannot be renewed beyond the next expiry date: Fri Jan 29 19:24:02 UTC 2016.This process will not be able to authenticate new SASL connections after that time (for example, it will not be able to authenticate a new connection with a Kafka Broker). Ask your system administrator to either increase the 'renew until' time by doing : 'modprinc -maxrenewlife null ' within kadmin, or instead, to generate a keytab for null. Because the TGT's expiry cannot be further extended by refreshing, exiting refresh thread now. (org.apache.kafka.common.security.kerberos.Login) | |
| [2016-01-29 09:24:20,146] WARN Fetching topic metadata with correlation id 0 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,156] ERROR fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.utils.CoreUtils$) | |
| kafka.common.KafkaException: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] 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.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,167] WARN Fetching topic metadata with correlation id 1 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,175] ERROR Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.producer.async.DefaultEventHandler) | |
| [2016-01-29 09:24:20,283] WARN Fetching topic metadata with correlation id 2 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,285] ERROR fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.utils.CoreUtils$) | |
| kafka.common.KafkaException: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] 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.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,294] WARN Fetching topic metadata with correlation id 3 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,302] ERROR Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.producer.async.DefaultEventHandler) | |
| [2016-01-29 09:24:20,404] WARN Fetching topic metadata with correlation id 4 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,405] ERROR fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.utils.CoreUtils$) | |
| kafka.common.KafkaException: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] 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.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,407] WARN Fetching topic metadata with correlation id 5 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,407] ERROR Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.producer.async.DefaultEventHandler) | |
| [2016-01-29 09:24:20,509] WARN Fetching topic metadata with correlation id 6 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,509] ERROR fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.utils.CoreUtils$) | |
| kafka.common.KafkaException: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] 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.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,511] WARN Fetching topic metadata with correlation id 7 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,511] ERROR Failed to collate messages by topic, partition due to: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.producer.async.DefaultEventHandler) | |
| [2016-01-29 09:24:20,613] WARN Fetching topic metadata with correlation id 8 for topics [Set(kafkahdtopic1)] from broker [BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667)] failed (kafka.client.ClientUtils$) | |
| java.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,614] ERROR fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] failed (kafka.utils.CoreUtils$) | |
| kafka.common.KafkaException: fetching topic metadata for topics [Set(kafkahdtopic1)] from broker [ArrayBuffer(BrokerEndPoint(0,wn0-kfk1-d.hdinsight.net,6667))] 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.nio.channels.ClosedChannelException | |
| at kafka.network.BlockingChannel.send(BlockingChannel.scala:122) | |
| at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) | |
| 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-01-29 09:24:20,616] ERROR Failed to send requests for topics kafkahdtopic1 with correlation ids in [0,8] (kafka.producer.async.DefaultEventHandler) | |
| [2016-01-29 09:24:20,617] 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) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment