今天,当我试图通过producer控制台将消息发送到consumer控制台时,会出现一条消息提示
[2016-11-02 15:12:58,168] ERROR Error when sending message to topic test with
key: null, value: 5 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问题还是Zookeeper问题?
2条答案
按热度按时间8mmmxcuj1#
在我重新启动整个服务器后,问题就消失了。
axr492tv2#
似乎客户端未能从kafka代理检索test-0的元数据。
如果您在iaas机器上运行kafka,请确保您能够连接到kafka代理,或者检查是否设置了“adverted.listeners”。