如何强制删除 Kafka 主题？

Question

我们有一个主题，即使在发出 kafka-topics 'delete' 命令后，它也不会消失。它只是说“TOPIC.A.B.C - 标记为删除”。此属性“delete.topic.enable=true”在所有代理上设置为 true。这是一个已知问题吗？是否有解决方法？就像手动删除主题文件夹和删除 zookeeper 配置中的主题条目一样？

Answer 1

强制删除主题

可以通过直接登录 ZooKeeper shell 并从集群中删除主题元数据来删除标记为删除的 Kafka 主题。我们还建议从与主题关联的每个代理中删除日志段。

1. 动物园管理员外壳
2. rmr /config/topics/
3. rmr /brokers/topics/
4. rmr /admin/delete_topics/
5. 对于每个代理：
   • 关闭代理
   • rm -R ${log.dirs}/-*
   • 启动代理

注意：步骤 5 应小心执行，以确保您只删除要删除的主题的日志目录