1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

2、Kafka 删除topic的命令是:

./bin/kafka-topics  --delete --zookeeper 【zookeeper server】  --topic 【topic name】

如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enable=true,那么此时的删除并不是真正的删除,而是把topic标记为:marked for deletion

你可以通过命令:./bin/kafka-topics --zookeeper 【zookeeper server】 --list 来查看所有topic

此时你若想真正删除它,可以如下操作:

(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 的config中也有有关topic的信息: ls /config/topics/【topic name】暂时不知道有什么用

总结:

彻底删除topic:

1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录

2、如果配置了delete.topic.enable=true直接通过命令删除,如果命令删除不掉,直接通过zookeeper-client 删除掉broker下的topic即可。

转载于:https://www.cnblogs.com/daochong/p/6421048.html

kafka删除topic及其相关数据相关推荐

  1. kafka删除topic时,显示marked for deletion

    kafka删除topic时,显示marked for deletion 1.查看三个端口的zookeeper和Kafka是否全部启动 2.查看 kafka/config/server.properti ...

  2. kafka查看topic中的数据_实战!Kafka Manager能统计出Topic中的记录条数吗?

    问题描述 今天现场实施同事说Kafka Manager上显示有3500w条记录,但使用我们的平台落地后,一统计发现只有2200w条记录,这是不是说明我们的平台存在丢数据的可能. 经了解,对接方是通过如 ...

  3. kafka消费之kafka查看topic是否有数据

    配置config文件为:server.properties 脚本在 kafka/bin路径下 启动kafka: ./kafka-server-start.sh ../config/server.pro ...

  4. kafka删除topic

    删除已经创建的topic 删除toipc主要使用:kafka-topics  --delete --zookeeper  zkip:zkport  --topic topicname命令删除:但是如果 ...

  5. Kafka删除topic Note: This will have no impact if delete.topic.enable is not【另外强烈推荐一个kafka小工具】

    vi /opt/kafka/config/server.properties 需要server.properties中设置delete.topic.enable=true否则只是标记删除或者直接重启. ...

  6. kafka彻底删除topic(cleanup policy)、清除特定topic数据

    一.彻底不需要该topic了 假设topic为test-0921 步骤如下: ①$KAFKA/bin/kafka-topics.sh --delete --zookeeper Desktop:2181 ...

  7. kafka删除队列_kafka 消息队列

    kafka是使用Java和Scala编写的一个快速可扩展的高吞吐量的分布式消息队列系统. kafka将数据持久化存储到磁盘上,自带分区和副本机制,因而具有较好的持久化保证. 但是kafka的消息消费没 ...

  8. kafka delete topic,marked for deletion

    kafka 删除topic 提示marked for deletion [root@logSer config]# kafka-topics.sh --delete --zookeeper local ...

  9. kafka如何彻底删除topic及数据

    前言: 删除kafka topic及其数据,严格来说并不是很难的操作.但是,往往给kafka 使用者带来诸多问题.项目组之前接触过多个开发者,发现都会偶然出现无法彻底删除kafka的情况.本文总结多个 ...

最新文章

  1. 张立贤:积跬步至千里,我与地学大数据的探索之旅 | 提升之路系列(五)
  2. python命令行添加Tab键自动补全
  3. 如果记录没有跟得上创造和学习
  4. python最快的循环方法_【转】【Python效率】五种Pandas循环方法效率对比
  5. jdbc如何写csv文件_Java:将JDBC结果集作为CSV流化
  6. Linux之文件通信
  7. LeetCode 1855. 下标对中的最大距离(双指针)
  8. mysql优化有哪些着手点_mysql的优化总结
  9. Java Singleton类中的线程安全
  10. MySQL max_allowed_packet
  11. JAVA遇上HTML-----JSP 篇基本概念
  12. 烧写树莓派系统,SSH配置,无屏登录流程
  13. Atitit.程序包装exe启动器 打包 发布 设计 -生成exe java
  14. 把.Net开发环境迁移到Linux上去
  15. 源码 | 幽灵交易者策略
  16. 传统蒙文字体_关于传统蒙古文网页的国际标准编码及字体处理技术
  17. 单片机原理与应用以及C51编程技术——硬件体系结构梳理
  18. 【已解决】script标签里提示Emmet Abbreviation问题(Html和CSS的语法)
  19. centos下设置屏保
  20. 服务器重装系统c盘过大,一键重装系统c盘变大了

热门文章

  1. Ubuntu 16.04 orb-slam2配置
  2. 移动CRM的客户价值细分
  3. CentOS7部署(Mysql) MariaDB Galera Cluster 10.1记录
  4. 查看当前Linux系统的发行版本命令详解
  5. 第五章 mybatis批量更新update
  6. 光线跟踪是什么? 光能传递(radiosity lighting)是什么?
  7. 边缘计算 VS 云计算,谁才是未来?
  8. 机器学习小字典(一)——SVM
  9. 铁乐学python_day02-作业
  10. 【三边定位】 演示程序V0.1