删除Kafka的Topic(提示:marked for deletion)

问题:

删除topic时标记删除marked for deletion但未真正的删除

删除Kafka的Topic(提示:marked for deletion)

 解决方法:

1.修改server.properties,并重启kafka

delete.topic.enable=true

2.再次删除topic

./kafka-topics.sh --delete --topic 主题名 --zookeeper 127.0.0.1:2181

3.可能仍提示marked for deletion

4.继续操作,通过zookeeper客户端zkCli.sh删除

zkCli.sh

5.查看topics目录下所有topic

ls /brokers/topics

6.删除指定topic

deleteall /brokers/topics/主题名

7.再次查看topic列表,应该已删除

./kafka-topics.sh --list --zookeeper 127.0.0.1:2181

8.删除kafka存储目录(按需)

kafka存储目录由”server.properties”文件中的”log.dirs”参数指定,默认为”/tmp/kafka-logs”。

删除该目录下topic相关目录。

本文来自网络,不代表协通编程立场,如若转载,请注明出处:https://net2asp.com/1c1df2f055.html