Kafka如何彻底删除topic

环境描述

Kafka集群环境如下,三台broker,三台zookeeper,搭建在k8s上
Kafka高可用架构图

最近搭建为客户提供kafak生产支持,客户有一个测试topic,因为之前使用的是单节点,开发在测试时创建的topic只有一个replication,一个partition,对有三个broker的集群来说这样显然发挥不了Kafka的高并发性和数据安全性,客户又不想改topic名,所以首先想修改topic

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
bin/kafka-topics.sh --delete --zookeeper 10.109.47.81:2181,10.96.173.143:2181,10.106.174.196:2181 --topic my_topic

在这里插入图片描述
再次查看topic
在这里插入图片描述
这个topic只是被标记下线数据还在没有完全删除,根据提示查看配置文件delete.topic.enable
在这里插入图片描述

修改为如下:

Logo

K8S/Kubernetes社区为您提供最前沿的新闻资讯和知识内容

更多推荐