如何在Apache Kafka中删除主题

Question

我需要在kafka-0.8.2.2.3中删除一个主题。我已使用以下命令删除该主题：

bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic DummyTopic

该命令已成功执行，但是当我运行命令以列出主题时，我可以看到该主题仍然存在，并且显示 标记为“删除” 。

bin/kafka-topics.sh --list --zookeeper localhost:2181
DummyTopic - marked for deletion

当我创建主题DummyTopic时，它会输出异常，该主题已存在，下面是堆栈跟踪：

Error while executing topic command Topic "DummyTopic" already exists.
kafka.common.TopicExistsException: Topic "DummyTopic" already exists.
    at kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK(AdminUtils.scala:248)
    at kafka.admin.AdminUtils$.createTopic(AdminUtils.scala:233)
    at kafka.admin.TopicCommand$.createTopic(TopicCommand.scala:92)
    at kafka.admin.TopicCommand$.main(TopicCommand.scala:54)
    at kafka.admin.TopicCommand.main(TopicCommand.scala)

请让我知道如何删除该主题。

Answer 1

从0.8.2.x版本开始支持删除主题。您必须delete.topic.enable首先在所有代理上启用主题删除（设置为true）。

注意：从1.0.x开始，delete.topic.enable默认情况下功能是稳定的true。

请按照以下逐步过程手动删除主题

1. 停止 Kafka 服务器
2. 删除主题目录，每个 代理 （如在定义logs.dirs和log.dir属性）与rm -rf命令
3. 连接到 Zookeeper 实例：zookeeper-shell.sh host:port
4. 在 Zookeeper 实例中：
   1. 使用以下方式列出主题： ls /brokers/topics
   2. 使用以下方法从 ZooKeeper中 删除主题文件夹：rmr /brokers/topics/yourtopic
   3. 退出Zookeeper实例（Ctrl + C）
5. 重新启动 Kafka 服务器
6. 使用此命令确认是否已删除 kafka-topics.sh --list --zookeeper host:port