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

kafka删除topic中的数据_kafka删除数据删除topic里面的数据这里没有单独的清空数据的命令,这里要达到清空数据的目的只需要以下步骤:一、如果当前topic没有使用过即没有传输过信息:可以彻底删除。二、如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(markedfordeletion)。想要彻底删除topic数据要经过下面两个步骤:①:删除topic,重新用创建to…

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新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

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

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/181270.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • Sublime Text3+常用插件汇总[通俗易懂]

    Sublime Text3+常用插件汇总[通俗易懂]SublimeTextSublimeText官网:https://www.sublimetext.com/下载所需要的SublimeText版本,根据提示安装。插件安装:直接下载安装包解压缩到Packages目录(preferences===>BrowsePackages显示已安装的插件)。 用PackageControl安装插件:1.按Ctrl+`(…

    2022年6月24日
    28
  • OCX制作CAB,数字签名制作

    OCX制作CAB,数字签名制作从网上找了些相关的资料,最终制作成功,做个小的总结:首先准备好必须的工具如下:制作工具:iexpress.exe和makecab.exe,签名工具:cert2spc.exe,makecert.exe,signcode.exe下面我具体说如何使用他们来帮助我们制作需要的cab包。下面是我引用网上的资料信息.1.将ocx文件以及第三方dll文件打包成…

    2022年7月14日
    22
  • Java程序员是不是已经烂大街了?「建议收藏」

    Java程序员是不是已经烂大街了?「建议收藏」宽进严出,有人看一看面试题都可以混水摸鱼进去,进去容易,坚持下来的人很少,大部分都是代码搬运工,这些人其实不是严格的JAVA程序员,非常容易转到其他方面,比如做前端、测试、运维、产品、运营。能够坚持做5年以上JAVA开发的人不多。真正JAVA开发人员很缺,JAVA代码搬运工很多。这位网友说:中级程序员,高级程序员那就更缺了“烂大街”我可以认为是褒奖吧,行业在发展,从…

    2022年7月8日
    108
  • Java取绝对值(绝对值函数的使用方法)

    在Java中可以使用Math.abs()方法来方便的进行绝对值计算,例如:输入的是正数的时候直接返回即可,当是负数的时候返回它的相反数即可。使用三目运算符可以使用一行代码就能做到intvalue=Math.abs(-90);System.out.println(value);System.out.println(“*********”);inta=-59;System.out.println((a<0)?-a:a);…

    2022年4月17日
    51
  • 16天记住7000考研单词

    16天记住7000考研单词16天记住7000考研单词(第一天)1.WithmyownearsIclearlyheardtheheartbeatofthenuclearbomb.我亲耳清楚地听到原子弹的心脏的跳动。2.Nextyearthebeardedbearwillbearadearbabyintherear.明年,长胡子的熊将在后方产一头可爱的小崽.

    2022年5月29日
    35
  • 登录的时候出现token无效_token已过期

    登录的时候出现token无效_token已过期msg:‘无效token’,status:400原因:用第三方组件element-ui或者其他组件的单个功能上传图片,没有用到axios发请求,而是组件内部自己封装了一个ajax去发请求,组件内部封装的ajax不携带Authorization字段.解决方案:1.首先在上传组件中手动添加:headers:”headerObj”2.再设置上传组件的请求头,添加Authorization字段:就解决了。…

    2025年11月8日
    3

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号