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

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐