kafka删除Topic

查看所有Topic

bin/kafka-topics --zookeeper zkserver:2181 --list

注意

如果需要被删除topic 此时正在被程序 produce和consume，则这些生产和消费程序需要停止。

因为如果有程序正在生产或者消费该topic，则该topic的offset信息一致会在broker更新。调用kafka delete命令则无法删除该topic。

同时，需要设置 auto.create.topics.enable = false，默认设置为true。如果设置为true，则produce或者fetch 不存在的topic也会自动创建这个topic。这样会给删除topic带来很多意想不到的问题。

删除Topic

• 1. KAFKA删除Topic

  bin/kafka-topics  --delete --zookeeper zkserver:2181  --topic [topic-name]
  提示: Topic xxx is marked for deletion.

  如果KAFKA配置文件server.properties中，没有指定delete.topic.enable=true参数，那么运行了此命令并不是真的删除, 而是把topic标记为：marked for deletion。

• 2. zookeeper删除Topic

  bin/zkCli.sh -server zkserver:2181
  ls /brokers/topics
  找到要删除的topic，执行命令：rmr /brokers/topics/[topic name]

• 3. 删除KAFKA存储目录

  也就是server.properties文件log.dirs配置的目录，删除对应的topic分区数据

​ 参考：云+社区

• 本文作者： GaryWu
• 本文链接： https://garywu520.github.io/2019/02/28/kafka删除Topic/
• 版权声明： 本博客所有文章除特别声明外，均采用 MIT 许可协议。转载请注明出处！