kafka 彻底删除 topic

本贴最后更新于 2150 天前,其中的信息可能已经水流花落

#如果只是用 kafka-topics.sh 的 delete 命令删除 topic,会有两种情况:

  1. 如果当前 topic 没有使用过即没有传输过信息:可以彻底删除
  2. 如果当前 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

  • Kafka

    Kafka 是一种高吞吐量的分布式发布订阅消息系统,它可以处理消费者规模的网站中的所有动作流数据。 这种动作(网页浏览,搜索和其他用户的行动)是现代系统中许多功能的基础。 这些数据通常是由于吞吐量的要求而通过处理日志和日志聚合来解决。

    36 引用 • 35 回帖
  • topic
    1 引用

相关帖子

欢迎来到这里!

我们正在构建一个小众社区,大家在这里相互信任,以平等 • 自由 • 奔放的价值观进行分享交流。最终,希望大家能够找到与自己志同道合的伙伴,共同成长。

注册 关于
请输入回帖内容 ...