删除后重新创建的主题未定义Leader。ISR也是空的。我有一个Kafka集群的3个节点下管理3节点Zookeeper合奏。
Kafka - 2.5.8和zookeeper 3.4.7
我有一个名为“每日心跳-G1”的主题,这个主题被删除并重新创建。
该主题直接从zookeeper中删除,如下所示:
登录Zookeeper CLI并运行以下命令rmr /brokers/topics/Daily-heartbeat-G1
rmr /config/topics/Daily-heartbeat-G1
rmr /admin/delete_topics/Daily-heartbeat-G1
这篇文章,主题没有列出。
还从Kafka代理中删除了相应的目录,因为它仍然存在。
现在,当我们用相同的名称重新创建相同的主题时,它显示Leader为“None”,ISR为空。
不过,在此之后,我没有重新启动经纪人。
我的问题是:
1.是什么原因导致Topic没有Leader,或者为什么ISR对于这样重新创建的Topic是空的?其他新创建的主题都很好。
1.我应该在删除和重建后重新启动代理吗?
1.如果我不从Kafka目录中删除主题,直接从zookeeper中删除,如上图所示,是否会影响?
在以上的过程中,我是否遗漏了什么
1条答案
按热度按时间a7qyws3x1#
Kafka代理维护主题元数据,包括leader和ISR信息。当你直接在ZooKeeper中删除一个主题时,你删除了主题的元数据。创建同名的新主题不会自动重新生成元数据。
不建议直接从ZooKeeper删除主题。使用Kafka CLI(kafka-topics.sh或等效命令)删除主题更安全,因为它会正确更新元数据。
您可以尝试刷新 * 元数据缓存或重启Kafka broker。