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-02-17 09:02:36,876] エラー [0,32] の相関 ID を持つトピック ツイートのリクエストを送信できませんでした

この問題を解決する方法

前もって感謝します

4

1 に答える 1

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

adverted.host.name が server.properties ファイルで正しい値に設定されているかどうかを確認します

これらのいずれかが問題の解決に役立つか、または他の変更で解決できたかどうかをお知らせください。

于 2016-02-17T04:43:21.120 に答える