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)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • phpstorm2021.2.3 激活(已测有效)[通俗易懂]

    phpstorm2021.2.3 激活(已测有效),https://javaforall.net/100143.html。详细ieda激活码不妨到全栈程序员必看教程网一起来了解一下吧!

    2022年3月14日
    415
  • hibernate query_下列关于hibernate说法正确的是

    hibernate query_下列关于hibernate说法正确的是转自品略图书馆:http://www.pinlue.com/article/2020/03/0920/1310003985022.html以前写代码,总免不了编写登陆部分。在获取user的时候,只可能返回一个user实例,或者为null。以前使用以下方法实现。Java代码publicUserget(Stringid){Sessionsession=HibernateU…

    2022年9月30日
    0
  • python3在pycharm中为什么导入random模块不能用? TypeError: ‘module’ object is not callable…

    python3在pycharm中为什么导入random模块不能用? TypeError: ‘module’ object is not callable…

    2021年10月22日
    124
  • 带你详细了解,一致性哈希算法的实现原理

    带你详细了解,一致性哈希算法的实现原理一致性哈希算法在1997年由麻省理工学院的Karger等人在解决分布式Cache中提出的,设计目标是为了解决因特网中的热点问题,初衷和CARP十分类似。一致性哈希修正了CARP使用的简单哈希算法带来的问题,使得DHT可以在P2P环境中真正得到应用。但现在一致性哈希算法在分布式系统中也得到了广泛应用,研究过Memcached缓存数据库的人都知道,Memcached服务器端本身不提供分布式Cache的一致性,而是由客户端来提供,具体在计算一致性哈希时采用如下步骤:

    2022年7月27日
    4
  • hackbar功能简介

    hackbar功能简介SQL:提供三种数据库的sql查询语句,以及一些方便联合查询的语句XSS:提供xss攻击语句string.fromcharcode():将根据UNICODE值来输出xss语句htmlcharactor:将XSS语句转化为HTML字符实体(以&开头)alert(xss)statement:构建一条xss测…

    2022年5月18日
    72
  • linux卸载软件_centos7如何卸载

    linux卸载软件_centos7如何卸载1、首先使用:rpm-qa|grepjava,如下图所示:2、然后依次执行:rpm-e–nodepspython-javapackages-3.4.1-11.el7.noarch,其中python-javapackages-3.4.1-11.el7.noarch是包的名称,如下图所示:3、再次执行rpm-qa|grepjava进行查看,如下图所示:4…

    2022年9月22日
    0

发表回复

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

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