kafka彻底删除topic
2024-10-18 21:20:48
如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况:
- 如果当前topic没有使用过即没有传输过信息:可以彻底删除
- 如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked for deletion)。
要彻底把情况2中的topic删除必须把kafka中与当前topic相关的数据目录和zookeeper与当前topic相关的路径一并删除。
相关组件的版本
zookeeper: 3.4.6
kafka: 0.9.0.0
这里假设要删除的topic是test,kafka的zookeeper root为/kafka
删除kafka相关的数据目录
数据目录请参考目标机器上的kafka配置:server.properties -> log.dirs=/var/kafka/log/tmp
su rm -r /var/kafka/log/tmp/test*
删除kafka topic
/home/kafka/bin/kafka-topics.sh --delete --zookeeper HadoopMaster:/kafka --topic test
删除zookeeper相关的路径
- 打开zookeeper client
/home/ZooKeeper/bin/zkCli.sh
- 执行下面的命令
把test替换成你要删除的topic
#删除topic test的consumer group,如果有消费记录的话
rmr /kafka/consumers/test-group
rmr /kafka/config/topics/test
rmr /kafka/brokers/topics/test
rmr /kafka/admin/delete_topics/test
完成
重启zookeeper和kafka可以用下面命令查看相关的topic还在不在:
/home/kafka/bin/kafka-topics.sh --list --zookeeper HadoopMaster:/kafka
转载请注明出处:http://www.cnblogs.com/keitsi/p/5580686.html
最新文章
- python from __future__ import division
- (转)SQL 优化原则
- NIS域配置详解
- GHOST中DISK TO DISK 和DISK FROM to image的区别
- java@ LinkedList 学习
- [openMP] OpenMP在visual studio和mac上的配置
- 找出数组前N大的数
- Linux学习笔记15——GDB 命令详细解释【转】
- Plugin For KanColleViewer – Provissy Tools V1.0
- CSS实现两端对齐效果
- [SDOI2015]星际战争
- html 自定义上传图片样式,并回显
- session and cookie简析
- 洛谷P3868 [TJOI2009]猜数字(中国剩余定理,扩展欧几里德)
- Expm 9_2 有向图的强连通分量问题
- [luogu2172] 部落战争
- 【Android】Android如何实现手机震动
- 每天一道剑指offer-二叉树的下一个结点
- Gradle Goodness: Add Incremental Build Support to Custom Tasks with Annotations
- 解决 Package test is missing dependencies for the following libraries: libcrypto.so.1.0.0
热门文章
- 马上着手开发Mac应用程序
- BufferedReader和BufferedWriter读写文件(转载)
- OpenJDK与JDK的区别及Ubuntu下的安装方法
- Install_pygments
- [Hive - LanguageManual ] Explain (待)
- 集群——LVS理论(转)
- Android实例-读取设备联系人(XE8+小米2)
- [C语言 - 3] 字符串
- UVaLive 7371 Triangle (水题,判矩形)
- Castle ActiveRecord学习实践