#如果只是用 kafka-topics.sh 的 delete 命令删除 topic,会有两种情况:
- 如果当前 topic 没有使用过即没有传输过信息:可以彻底删除
- 如果当前 topic 有使用过即有过传输过信息:并没有真正删除 topic 只是把这个 topic 标记为删除(marked for deletion)。
要彻底把情况 2 中的 topic 删除必须把 kafka 中与当前 topic 相关的数据目录和 zookeeper 与当前 topic 相关的路径一并
删除 kafka 相关的数据目录
数据目录请参考目标机器上的 kafka 配置:server.properties -> log.dirs=xxxx
su rm -r /xxx/test*
删除 kafka topic
/home/kafka/bin/kafka-topics.sh --delete --zookeeper zkhost:2181 --topic test
删除 zookeeper 相关的路径
##删除 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
欢迎来到这里!
我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。
注册 关于