如何在Apache Kafka中删除主题

从0.8.2.x版本开始支持删除主题。您必须

delete.topic.enable

注意：从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