Zookeeper 在Kafka中,主题是删除娱乐帖子后无法获得领导者

d6kp6zgx  于 2023-10-14  发布在  Apache
关注(0)|答案(1)|浏览(156)

删除后重新创建的主题未定义Leader。ISR也是空的。我有一个Kafka集群的3个节点下管理3节点Zookeeper合奏。
Kafka - 2.5.8和zookeeper 3.4.7
我有一个名为“每日心跳-G1”的主题,这个主题被删除并重新创建。
该主题直接从zookeeper中删除,如下所示:
登录Zookeeper CLI并运行以下命令
rmr /brokers/topics/Daily-heartbeat-G1rmr /config/topics/Daily-heartbeat-G1rmr /admin/delete_topics/Daily-heartbeat-G1
这篇文章,主题没有列出。
还从Kafka代理中删除了相应的目录,因为它仍然存在。
现在,当我们用相同的名称重新创建相同的主题时,它显示Leader为“None”,ISR为空。
不过,在此之后,我没有重新启动经纪人。
我的问题是:
1.是什么原因导致Topic没有Leader,或者为什么ISR对于这样重新创建的Topic是空的?其他新创建的主题都很好。
1.我应该在删除和重建后重新启动代理吗?
1.如果我不从Kafka目录中删除主题,直接从zookeeper中删除,如上图所示,是否会影响?
在以上的过程中,我是否遗漏了什么

a7qyws3x

a7qyws3x1#

Kafka代理维护主题元数据,包括leader和ISR信息。当你直接在ZooKeeper中删除一个主题时,你删除了主题的元数据。创建同名的新主题不会自动重新生成元数据。
不建议直接从ZooKeeper删除主题。使用Kafka CLI(kafka-topics.sh或等效命令)删除主题更安全,因为它会正确更新元数据
您可以尝试刷新 * 元数据缓存重启Kafka broker。

相关问题