大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。
Jetbrains全系列IDE稳定放心使用
删除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
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/181270.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...