2016-02-17 43 views
0
kafka.common.KafkaException: fetching topic metadata for topics [Set(tweets)] from broker [ArrayBuffer(id:0,host:localhost,port:9092)] failed 
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:72) 
at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82) 
at kafka.producer.async.DefaultEventHandler$$anonfun$handle$2.apply$mcV$sp(DefaultEventHandler.scala:78) 
at kafka.utils.Utils$.swallow(Utils.scala:172) 
at kafka.utils.Logging$class.swallowError(Logging.scala:106) 
at kafka.utils.Utils$.swallowError(Utils.scala:45) 
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:78) 
at kafka.producer.Producer.send(Producer.scala:77) 
at kafka.javaapi.producer.Producer.send(Producer.scala:33) 
at com.aail.kafka.KafkaConnection.r(KafkaConnection.java:141) 
at com.aail.kafka.Postgresconnection.main(Postgresconnection.java:40) 
Caused by: java.nio.channels.ClosedChannelException 
at kafka.network.BlockingChannel.send(BlockingChannel.scala:100) 
at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73) 
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72) 
at kafka.producer.SyncProducer.send(SyncProducer.scala:113) 
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58) 
... 10 more 

[2016年2月17日09:02:36876]錯誤未能與相關IDS在[0,32]Apache Kafka Producer計劃拋出kafka.common.KafkaException,java.nio.channels.ClosedChannelException和kafka.common。如何解決它?

發送的主題鳴叫請求如何解決這個問題的任何幫助,將不勝感激

在此先感謝

回答

0

我會按照下面的要點來調查您可能已經簽入。

檢查控制檯生產者和控制檯使用者是否按預期工作。以下是啓動Zookeeper和Kafka服務器並創建主題後的命令。

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 
    bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning 

檢查是否advertised.host.name被設定爲在server.properties正確的值文件

請不要讓我知道如果任何可以幫助他們解決問題,或者如果你能以解決它與其他一些變化。

+0

我檢查了它,但沒有找到任何解決方案 - Mehul –

+0

如果你能請給我一些關於你如何運行kafka和zookeeper以及kafka版本的更多信息,也許我可以嘗試重現錯誤 – Mehul

+0

目前我使用的是kafka-version:0.8.2,而我的Kafka-Producer-Program可以正常工作15-20小時,之後就是拋出這個異常。我不明白爲什麼它是獲得。你可以檢查一次 - Mehul –

相關問題