我为啥要删除,卡死了呗。。。
1、设置auto.create.topics.enable = false,并认真把生产和消费程序彻底全部停止。
2、server.properties 设置 delete.topic.enable=true 如果没有设置 delete.topic.enable=true,则调用kafka 的delete命令无法真正将topic删除,而是显示(marked for deletion)
3、调用命令删除topic: - ./bin/kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【topic name】
复制代码
4、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/data/kafka-logs")相关topic的数据目录。 |