概述 在平时对kafka的运维工作中,我们经常会由于某些原因去删除一个topic,比如这个topic是测试用的,生产环境中需要删除。或者我想扩容topic的同时,这个topic中的数据我不想要了,这时候删除topic,增加broker,再重新创建topic就会是比较简单的方法。但是kafka ...
手动: 删除kafka存储目录 server.properties文件log.dirs配置,默认为 tmp kafka logs 相关topic目录 删除zookeeper brokers topics 目录下相关topic节点 命令 手动: 删除kafka存储目录 server.properties文件log.dirs配置,默认为 tmp kafka logs 相关topic目录 如果你要删除 ...
2015-04-23 11:21 2 3426 推荐指数:
概述 在平时对kafka的运维工作中,我们经常会由于某些原因去删除一个topic,比如这个topic是测试用的,生产环境中需要删除。或者我想扩容topic的同时,这个topic中的数据我不想要了,这时候删除topic,增加broker,再重新创建topic就会是比较简单的方法。但是kafka ...
一、概述 生产环境中,有一个topic的数据量非常大。这些数据不是非常重要,需要定期清理。 要求:默认保持24小时,某些topic 需要保留2小时或者6小时 二、清除方式 主要有3个: 1. 基于时间 2. 基于日志大小 3. 基于日志起始偏移量 详情,请参考链接 ...
------------恢复内容开始------------ 最近测试环境的kafkaTopic太多太乱,大部分测试用的topic已经没有用了,就想着删掉。查阅了网上博客资料之后进行了操作。 1.有说在kafka的server配置文件中加上delete.topic.enable=true ...
3、Kafka 删除topic的命令是: ./bin/kafka-topics --dele ...
1、删除kafka存储目录(server.properties文件log.dirs配置,默认为"/tmp/kafka-logs")相关topic目录。 2、可以通过bin下面的 bin/kafka-topics.sh #如果kafaka启动时加载的配置文件中 ...
如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除 如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked ...
前言 我们都知道kafka管理的主要对象之一就是topic。对topic的增伤查改是最基本的操作。但是如果你使用kafka命令删除topic时报错该怎么办?就只能卸载掉kafka重新安装了吗? 当然不是了。我们可以使用zookeeper去物理删除topic。 正文 由于前段时间迁移云 ...
如果只是用kafka-topics.sh的delete命令删除topic,会有两种情况: 如果当前topic没有使用过即没有传输过信息:可以彻底删除 如果当前topic有使用过即有过传输过信息:并没有真正删除topic只是把这个topic标记为删除(marked ...