首页
学习
活动
专区
工具
TVP
发布
您找到你想要的搜索结果了吗?
是的
没有找到

kafka批量删除topic_kafka查看topic数据量

前言: 利用kafka命令删除topic不成功。...kafka-topics.sh –zookeeper *.192.0.128:2181/kafka_yes –delete –topic test 原因&解决方式 配置文件未将delete.topic.enable...=true,导致删除命令未及时生效; 解决方式: 第一种:找到conf目录下server.properties配置文件,修改delete.topic.enable=true,代表删除立即生效; [root...kafka配置,需要点击delete.topic.enable 这个配置打对号 第二种:不修改delete.topic.enable=true配置文件的情况下,删除命令执行后,重启kafka服务,也可以使主题删除成功...; 配置文件已经设置delete.topic.enable=true,删除命令执行后,还能看到topic名称; 原因:生产者和消费者并未停止执行,导致虽然删除了topic,但是生产者或者消费者运行时,

60730

kafka删除topic数据

kafka删除topic数据 一、概述 生产环境中,有一个topic的数据量非常大。这些数据不是非常重要,需要定期清理。...要求:默认保持24小时,某些topic 需要保留2小时或者6小时 二、清除方式 主要有3个: 1. 基于时间 2. 基于日志大小 3....topic 单个topic 针对单个topic策略,需要使用脚本kafka-configs.sh 此脚本不需要重启kafka就会生效!...名 输出: Configs for topic ‘test’ are 这个表示为策略为空 删除topic数据 如果需要删除topic所有数据,使用命令 bin/kafka-topics.sh –delete...注意:修改保留时间为10秒,但不是修改后10秒就马上删掉,kafka是采用轮训的方式,轮训到这个topic发现10秒前的数据都是删掉。

3.8K160

kafka删除topic数据

一、概述 生产环境中,有一个topic的数据量非常大。这些数据不是非常重要,需要定期清理。 要求:默认保持24小时,某些topic 需要保留2小时或者6小时 ? 二、清除方式 主要有3个: 1....topic 比如: log.retention.hours=3 表示保留3个小时 单个topic 针对单个topic策略,需要使用脚本kafka-configs.sh 此脚本不需要重启kafka就会生效...名 输出: Configs for topic 'test' are 这个表示为策略为空 删除topic数据 如果需要删除topic所有数据,使用命令 bin/kafka-topics.sh --delete... --topic test --zookeeper zookeeper-1.default.svc.cluster.local:2181 这个命令,请谨慎执行!!!...kafka是采用轮询的方式,轮询到这个topic时,删除10秒钟前的数据。

4.2K20

RabbitMQ Topic交换机

通过使用通配符模式,Topic交换机可以实现精确匹配或模糊匹配的消息路由。Topic交换机的基本概念Topic交换机根据消息的路由键和绑定键之间的模式匹配,将消息发送到与之匹配的队列。...Topic交换机的通配符有两种形式:*(星号):表示匹配一个单词。#(井号):表示匹配零个或多个单词。...Topic交换机的关键特点如下:模式匹配:Topic交换机根据消息的路由键和绑定键之间的模式匹配将消息发送给匹配的队列。灵活性:通过使用通配符模式,可以实现精确匹配或模糊匹配的消息路由。...队列绑定:队列需要将自己绑定到Topic交换机上,并指定绑定键,以接收与之匹配的消息。..."的Topic交换机。

25830
领券