在删除kafka topic时,有时候会发现无法彻底删除的情况,这里以cdh这个版本的 kafka 作为实验版本,给出一种删除kafka topic的方法。
环境说明:
环境 & 软件 | 版本 |
---|---|
LinuxOS | CentOS 7 |
CDH | cdh5.16.2 |
kafka | 0.11.0 , 基于ClouderaManager 以 parcel方式安装 |
核心配置:
1、topic自动删除开关置为truedelete.topic.enable=true
也可以在这里配置:
auto.create.topics.enable = false
注意:
设置为true时,在向topic里生产数据或查询一个不存在的 topic 时,将自动创建新的。
kafka-topics --delete --zookeeper dn3:2181 --topic rtdw_test_gmall.user_info
4、删除 kafka 日志数据目录数据文件,索引文件均存在于这个目录下。
搜索 log.dirs 查找实际的目录位置(如:/var/local/kafka/data), 在此目录下找到想要删除的topic。
注意:
1、一般Broker节点为多节点,所有节点都要做删除清理 *** 作。
2、如果设置了多个目录存储,也同样需要做删除清理 *** 作。
被 标记为 “marked for deletion” 的topic,位于:/admin/delete_topics下
目录导航至希望删除的节点的位置,在GUI中删除,或以如下命令行方式删除。
ls /brokers/topics
rmr /brokers/topics/【topic name】
ls /admin/delete_topics
rmr /admin/delete_topics/【topic name】
6、验证topic是否已被删除
kafka-topics --list --zookeeper dn3:2181
7、重启kafka 和 zoopeeper集群停kafka,停zookeeper,启动zookeeper,启动kafka
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)