apache-kafka - kafka-console-producer.sh TimeOutException

Question

我正在尝试使用 Kafka 控制台生产者将消息发送到在同一台机器上运行的 Kafka 代理。当我跑

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

我收到以下错误消息:

[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

当我检查 Kafka 代理是否正在监听端口 9092 时，它在那里并正在运行。如何调试为什么命令行生产者无法连接到代理？谢谢!

Answer 1

我遇到了同样的问题，似乎 Kafka 向 zookeeper 写入了错误的元数据。

获得通过的最简单方法是删除正在注册代理数据的 znode。即，如果您使用默认值，则名称应为“/brokers”，命令为:

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