删除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