如何删除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）。

关注这个循序渐进的过程为topics手动删除

1. 停止卡夫卡服务器
2. 与rm -rf命令

3. 连接删除的主题目录动物园管理员例如：zookeeper-shell.sh host:port

4. ls /brokers/topics

5. 使用从动物园管理员删除主题文件夹rmr /brokers/topics/yourtopic
6. 重启卡夫卡服务器
7. 确认它是否被删除或无法使用本命令 kafka-topics.sh --list --zookeeper host:port