------------恢复内容开始------------
最近测试环境的kafkaTopic太多太乱,大部分测试用的topic已经没有用了,就想着删掉。查阅了网上博客资料之后进行了操作。
1.有说在kafka的server配置文件中加上delete.topic.enable=true然后使用命令./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】删除的。经过验证可行。
2:另一种就是不用在server配置文件添加参数,直接通过zookeeper来删除。首先在zk的bin目录下执行./zkCli.sh命令,然后执行ls /admin/delete_topics查看zk下的所有topic,然后执行deleteall /brokers/topics/【topic name】来删除topic。
上面两种命令亲测有效,在删除前需要把topic相关的生产者和消费者全部都停掉,不然会导致删除不成功,