kafka-console-producer.sh TimeOutException

Question

Kafkaコンソールプロデューサを使用して同じマシン上で実行されているKafkaブローカにメッセージを送信しようとしています。カフカブローカーはポート9092をリッスンしている場合、私がチェックしたとき、それが稼働中である

[2016-06-29 15:00:44,069] ERROR Error when sending message to topic test with key: null, value: 11 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) 
org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for test-0 

：私は

echo "Hello world" | ./kafka-console-producer.sh --broker-list localhost:9092 --topic test 

を実行すると、私は、次のエラーメッセージが表示されます。コマンドラインプロデューサがブローカに接続できない理由をデバッグするにはどうすればよいですか？ありがとうございました！

Answer 1

私は同じ問題を経験しました。カフカが動物園に間違ったメタデータを書いたようです。

これをパスする最も簡単な方法は、ブローカのデータが登録されているznodeを削除することです。すなわちデフォルトを使用する場合、名前は「/ブローカー」とコマンドを次のようになります。

$ zkCli.sh 
... 
[zk: localhost:2181(CONNECTED) 1] rmr /brokers