首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >抓取元数据kafka {test=LEADER_NOT_AVAILABLE}出错?

抓取元数据kafka {test=LEADER_NOT_AVAILABLE}出错?
EN

Stack Overflow用户
提问于 2019-12-09 04:40:37
回答 2查看 3.3K关注 0票数 3

在运行这些简单的命令后,我得到了这个错误-

我启动了Zookeeper和Kafka服务器

我执行以下命令:

代码语言:javascript
运行
复制
./kafka-topics --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

并执行以下命令:

代码语言:javascript
运行
复制
./kafka-console-producer --broker-list localhost:9092 --topic test

我获得了一个WARN列表,如下所示:

代码语言:javascript
运行
复制
[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)

我做错什么了?谢谢

EN

回答 2

Stack Overflow用户

发布于 2019-12-10 14:26:28

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

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

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

票数 2
EN

Stack Overflow用户

发布于 2019-12-10 15:57:00

我想添加评论,但似乎我不能。只需通过此链接。有人遇到了类似的问题,似乎问题不是你做了什么,而是一些不同的东西。

链接:https://grokbase.com/t/kafka/users/134qvay38q/leadernotavailable-exception

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/59239708

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档