删除 kafka topic 数据报错 is marked for deletion 解决方法

文章

林里克斯

删除 kafka topic 数据报错

$ cd /data/kafka
$ bin/kafka-topic.sh --delete --zookeeper 10.10.112.110:2181,10.10.112.111:2181,10.10.112.112:2181 --topic topic_name
Topic topic_name is marked for deletion.
Note：This will have no impact if delete.topic.enable is not set to true.

解决方法：

1.报错已经给了一个解决方法

Note：This will have no impact if delete.topic.enable is not set to true.
#将 kafka 配置文件 delete.topic.enable 参数设置为 true

设置为 true 后重启 kafka 然后再删除

2.通过 zookeeper 的控制台删除

$ cd /dara/zookeeper
$ ./zkCli.sh
[zk：localhost:2181(CONNECTED) 0] ls /brokers/topics
#查看目前下面所有的 topic
[zk：localhost:2181(CONNECTED) 1] ls /brokers/topics/topic_name
topic_name
#查看具体的某一个 topic
[zk：localhost:2181(CONNECTED) 2] deleteall /brokers/topics/topic_name

WATCHER::

WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/brokers/topics
#删除 topic

3.删除 kafka 存储目录（server.properties 文件 log.dirs 配置，默认为 /data/kafka-logs）相关 topic 的数据目录

$ rm -rf /dara/kafka/data/topic_name_*
#如果kafka 有多个 broker，且每个 broker 配置了多个数据盘（比如 /data/kafka/data1,/data/kafka/data2 ...），且 topic 也有多个分区和 replica，则需要对所有 broker 的所有数据盘进行扫描，删除该 topic 的所有分区数据

Over~