kafka0.8.2以下版本删除topic
2015-08-14 21:47
239 查看
一些说明
kafka0.8.2及以上版本已经支持delete命令删除topic,可是之前的版本要是想删除topic还是要费一番手脚,绝对是个体力活。。。该方法最好仅在线下开发环境中使用,毕竟要重启zookeeper和broker
步骤
1.在zk中删除topic信息(test)$KAFKA_HOME/bin/kafka-run-class.sh kafka.admin.DeleteTopicCommand --zookeeper zk1:2181,zk2:2181,zk3:2181 --topic test
关闭zookeeper和broker
$ZOOKEEPER_HOME/bin/zkServer.sh stop $KAFKA_HOME/bin/kafka-server-stop.sh
2.删除topic消息
进入kafka指定的log.dir位置,删除所有test相关的partition(如果你的partition较多并且分布到各个broker上,过程还是很辛苦的。)
同时修改日志目录下的
recovery-point-offset-checkpoint和
replication-offset-checkpoint文件
删除其中相关的partition信息,并且把文件中第二行的partition总数减少。
3.重启服务
任务完成,重新启动zk和broker
$ZOOKEEPER_HOME/bin/zkServer.sh start $KAFKA_HOME/bin/kafka-server-start.sh
相关文章推荐
- kafka0.8.2以下版本删除topic
- kafka0.8.2以下版本删除topic
- kafka0.8.2以下版本删除topic
- Linux的fdisk命令详解
- 第四天:内存管理-property参数
- hadoop论坛实战项目
- OpenCV 下载驿站(百度云盘下载,同步更新)
- openstack某节点空间不足
- linux下的命令格式
- Java集群优化——dubbo+zookeeper构建高可用分布式集群
- CentOS 7 编译64位Hadoop2.7.1
- [优化篇]OpenStack的Cinder后端存储技术——NFS
- 哪款Linux发行版是你的最佳选择呢?
- linux下使用g++编译包含多个库的c++的方法
- centos6.5 切换桌面模式与命令行模式
- Linux的mount命令详解
- centos笔记
- web网站服务(二)
- 用dfs序维护树结构
- OpenLayers访问Geoserver发布的地图