在运行这些简单的命令后,我得到了这个错误-
我启动了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)
我做错什么了?谢谢
发布于 2019-12-10 14:26:28
如果您的代理将auto.create.topics.enable
设置为true,则此错误将是暂时的,您应该能够生成消息,而不会出现任何进一步的错误。这只是因为生产者正在请求关于它想要写入的主题的元数据,但是该主题在集群中不存在,并且分区领导者(生产者想要写入的位置)还不存在。如果您重试,代理将创建主题,并且命令将正常工作。
如果上面的配置设置为false,那么代理不会在客户端的第一个请求时自动创建主题,因此您必须预先创建它。
最后,但这不是您的情况,当主题存在时,甚至可能发生上述错误,但是,例如,作为特定主题分区的领导者的代理关闭,并且正在进行新的领导者选举。
发布于 2019-12-10 15:57:00
我想添加评论,但似乎我不能。只需通过此链接。有人遇到了类似的问题,似乎问题不是你做了什么,而是一些不同的东西。
链接:https://grokbase.com/t/kafka/users/134qvay38q/leadernotavailable-exception
https://stackoverflow.com/questions/59239708
复制相似问题