kafka彻底删除topic

Posted 2020-11-15 zf201149

第一种方式：

1.修改server.properties文件

delete.topic.enable=true

auto.create.topics.enable=false

2.确保所有的生产者，消费者都已经停掉

3.执行bin/kafka-topics.sh --delete --zookeeper localhost:2181 --topic demo

4.执行bin/kafka-topics.sh --list --zookeeper localhost:2181

 

第二种方式：手工删除

1.在server.properties文件中配置的logs.dir路径中执行rm -rf demo*,将文件全部删除

2.在zookeeper中客户端中,使用./zkCli.sh

[zk: localhost:2181(CONNECTED) 0] ls /brokers/topics
[__consumer_offsets, demo, test]
[zk: localhost:2181(CONNECTED) 1] rmr /brokers/topics/demo
The command ‘rmr‘ has been deprecated. Please use ‘deleteall‘ instead.
[zk: localhost:2181(CONNECTED) 2] deleteall /brokers/topics/demo
Node does not exist: /brokers/topics/demo
[zk: localhost:2181(CONNECTED) 3] ls /admin/delete_topics/demo
Node does not exist: /admin/delete_topics/demo

注意第二种方式可以不用重启kafka与zookeeper

彻底删除topic：

 1、删除kafka存储目录（server.properties文件log.dirs配置，默认为"/tmp/kafka-logs"）相关topic目录

  2、如果配置了delete.topic.enable=true直接通过命令删除，如果命令删除不掉，直接通过zookeeper-client 删除掉broker下的topic即可。

 

 

 

  

 

 

s