删除kafka的consumer和topics
谨慎操作
kafka
版本0.10
删除 consumers
原因: 重置 offset
, 或者是强迫症想清空不用的 consumer
操作:
# 进入控制台
bin/zookeeper-shell.sh localhost:2181
# 查看所有消费者
ls /consumers
# fuck
rmr /consumers/hangou
# 再查看 没了
ls /consumers
删除 topics
原因: 腾出空间
操作:
- 物理删除数据
# 进入 server.properties 里配置的数据目录 log.dirs=/data/kafka-logs
cd /data/kafka-logs/
# 删除对应 topic 目录, 配置了多少分区这就有多少目录
rm -rf lion_sql-log*
- 删除 zookeeper 里的记录
# 进入控制台
bin/zookeeper-shell.sh localhost:2181
# 查看当前的所有 topics, 发现刚删除的 topics 还在这里躺着
ls /brokers/topics/
# fuck you
rmr /brokers/topics/lion_sql-log
# 再查看 没了
ls /brokers/topics
kafka删除弃用的groupid
1
2
3
4
5
6
7
|
登录zookeeper客户端 cd zookeeper-3.4.10 sh zkCli.sh 查看groupid信息 [zk:localhost:2181(CONNECTED) 1] ls /consumers/ 删除弃用的groupid,groupid为 test -group [zk:localhost:2181(CONNECTED) 2] rmr /consumers/test-group |
转载请注明:SuperIT » 删除kafka的consumer和topics