kafka删除topic


------------恢复内容开始------------

最近测试环境的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相关的生产者和消费者全部都停掉,不然会导致删除不成功,

 


免责声明!

本站转载的文章为个人学习借鉴使用,本站对版权不负任何法律责任。如果侵犯了您的隐私权益,请联系本站邮箱yoyou2525@163.com删除。



 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM