网站首页 > 技术文章 正文
删除kafka topic不仅仅是在Kafka Manager上点击下Delete Topic,或者直接命令kafka-topics --delete --zookeeper 【zookeeper server:port】 --topic 【待删除的topic name】删除这么简单
前提条件
- 待删除的topic生产者和消费者需要停止,同时确认topic的自动创建被关闭,防止其他疏忽的原因(比如消费者没有停止,导致topic再次自动创建) auto.create.topics.enable = false
- kafka服务端配置需要开启 delete.topic.enable=true,否则无法删除,只是标识markerd for deletion
删除topic
- 执行 bin/kafka-topics --delete --zookeeper [ zookeeper server:port ] --topic [ 待删除的topic name ]
- 清理kafka数据目录下对应topic的数据,注意检查每个broker。一般这样就完成topic删除的工作了,若还无法删除需要到zk里去清理下kafka元数据。
若无法删除,检查zk
- 检查zookeeper 里kafka数据信息
# 使用zk客户端zkCli.sh 登陆到zk
bin/zkCli.sh -server 【zookeeper server:port】
# 检查kafka topic信息,默认以下目录,根据实际目录检查
ls /brokers/topics
# 删除对应topic信息
rmr /brokers/topics/【topic name】
如果topic 是被标记为 marked for deletion,则通过命令 ls /admin/delete_topics,找到要删除的topic,然后执行命令:
rmr /admin/delete_topics/【topic name】
若忘记关停生产者和消费者,还需要删除topic在zk上面的消费节点记录、配置节点记录,比如:
rmr /consumers/【consumer-group】
rmr /config/topics/【topic name】
检查topic是否删除
bin/kafka-topics.sh --list --zookeeper 【zookeeper server:port】若列表没有,恭喜你,topic已被完全删除。
猜你喜欢
- 2024-12-12 Kafka监控与指标解析-UnderReplicatedPartitions
- 2024-12-12 聊聊 Kafka: Consumer 源码解析之 ConsumerNetworkClient
- 2024-12-12 为什么Kafka依赖ZooKeeper?
- 2024-12-12 一款Kafka可视化Web界面管理工具:CMAK
- 2024-12-12 MongoDB 数据同步kafka
- 2024-12-12 kafka快速入门到精通
- 2024-12-12 SpringBoot集成Kafka+Kafka优化问题
- 2024-12-12 kafka consumer 配置详解
- 2024-12-12 kafka生产者配置详解
- 2024-12-12 Kafka两种集群详解和搭建教程
- 最近发表
- 标签列表
-
- cmd/c (90)
- c++中::是什么意思 (84)
- 标签用于 (71)
- 主键只能有一个吗 (77)
- c#console.writeline不显示 (95)
- pythoncase语句 (88)
- es6includes (74)
- sqlset (76)
- apt-getinstall-y (100)
- node_modules怎么生成 (87)
- chromepost (71)
- flexdirection (73)
- c++int转char (80)
- mysqlany_value (79)
- static函数和普通函数 (84)
- el-date-picker开始日期早于结束日期 (76)
- js判断是否是json字符串 (75)
- c语言min函数头文件 (77)
- asynccallback (87)
- localstorage.removeitem (74)
- vector线程安全吗 (70)
- java (73)
- js数组插入 (83)
- mac安装java (72)
- 无效的列索引 (74)