kafka删除topic中的数据_kafka删除数据

删除topic里面的数据

这里没有单独的清空数据的命令，这里要达到清空数据的目的只需要以下步骤：

一、如果当前topic没有使用过即没有传输过信息：可以彻底删除。

二、如果当前topic有使用过即有过传输过信息：并没有真正删除topic只是把这个topic标记为删除（marked for deletion）。想要彻底删除topic数据要经过下面两个步骤：

①：删除topic,重新用创建topic语句进行创建topic

②：删除zookeeper中的consumer中的路径。

这里假设要删除的topic是test，kafka的zookeeper root为/kafka

删除kafka相关的数据目录

数据目录请参考目标机器上的kafka配置：server.properties -> log.dirs=/var/kafka/log/tmp

rm -r /var/kafka/log/tmp/test*

删除kafka topic

./kafka-topics.sh –zookeeper node3:2181,node4:2181,node5:2181 –delete –topic kfk

删除zookeeper相关的路径

（1）登录zookeeper客户端：命令：./bin/zookeeper-client

（2）找到topic所在的目录：ls /brokers/topics

（3）找到要删除的topic，执行命令：rmr /brokers/topics/【topic name】即可，此时topic被彻底删除。

另外被标记为marked for deletion的topic你可以在zookeeper客户端中通过命令获得：ls /admin/delete_topics/【topic name】，如果你删除了此处的topic，那么marked for deletion 标记消失

完成

重启zookeeper和kafka可以用下面命令查看相关的topic还在不在：

/home/kafka/bin/kafka-topics.sh –list –zookeeper HadoopMaster:2181/kafka

版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。

发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/181270.html原文链接：https://javaforall.cn