apache-kafka - 获取元数据 kafka {test=LEADER_NOT_AVAILABLE} 时出错？

Question

运行这些简单命令后出现错误 -

我启动了 Zookeeper 和 Kafka 服务器，

我执行命令:

./kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

并执行命令:

./kafka-console-producer --broker-list localhost:9092 --topic test

我得到了一个 WARN 列表，例如:

[2019-12-08 21:36:13,024] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 37 : {test=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)

我做错了什么？谢谢

Answer 1

如果您的代理将 auto.create.topics.enable 设置为 true，则此错误将是暂时的，您应该能够生成消息而不会出现任何进一步的错误。发生这种情况只是因为生产者正在询问有关它要写入的主题的元数据，但集群中不存在该主题，并且分区领导者(生产者要写入的位置)尚不存在。如果您重试，代理将创建主题并且该命令将正常工作。

如果上述配置设置为 false，则代理不会在客户端的第一个请求时自动创建主题，因此您必须预先创建它。

最后，但这不是你的情况，当主题存在时甚至可能发生上述错误，例如，作为特定主题分区的领导者的代理已关闭并且正在进行新的领导者选举。