Kafka如何彻底删除topic
环境描述
Kafka集群环境如下,三台broker,三台zookeeper,搭建在k8s上

最近为客户提供kafak生产支持,客户有一个测试topic,因为之前使用的是单节点,开发在测试时创建的topic只有一个replication,一个partition,对有三个broker的集群来说这样显然发挥不了Kafka的高并发性和数据安全性,客户又不想改topic名,所以首先想删除topic,重新创建(修改不能修改replication数)
case1:delete.topic.enable=false
查看所有topic
bin/kafka-topics.sh --list --zookeeper 10.109.47.81:2181,10.96.173.143:2181,10.106.174.196:2181
删除topic,my_topic

再次查看topic

这个topic只是被标记下线数据还在没有完全删除,根据提示查看配置文件delete.topic.enable

修改为如下:

case2:delete.topic.enable=true

case3:客户的情况
hhh这个topic无法删除,但是gtmc-topic 这个topic能删除

方法如下:
进入zookeeper集群
bin/zkCli.sh 如下为正常输出

rmr /brokers/topics/[your topic name] ## 比如test这个topic

网友评论