[转帖]kafka指定topic设置消息留存时间

kafka,指定,topic,设置,消息,留存,时间 · 浏览次数 : 0

小编点评

## 单个主题消息量缩小点执行命令 * 每个主题指定的消息留存时间缩小点。 * 此命令将指定 259200000 秒，即 75 天，的主题消息留存时间。 ```sh ./bin/kafka-configs.sh --bootstrap-server node1:9092 --entity-type topics --entity-name gaofengTest --alter --add-config retention.ms=259200000 ``` **知识点与官方知识档案匹配：** * 此命令与官方知识档案中关于设置主题消息留存时间的说明一致。 * 请参考官方文档了解更多有关主题消息留存时间的详细信息。 **其他补充：** * 此命令仅适用于 `kafka-configs.sh` 中的 `retention.ms` 参数。 * 此命令仅针对指定主题名称的配置。

正文

背景

单个主题消息量庞大，需要指定这个主题的消息留存时间缩小点

执行命令

./bin/kafka-configs.sh --bootstrap-server node1:9092 --entity-type topics --entity-name gaofengTest --alter --add-config retention.ms=259200000
修改完等几分钟，这个主题的消息量就下来了
在这里插入图片描述

文章知识点与官方知识档案匹配，可进一步学习相关知识

云原生入门技能树首页概览14690 人正在系统学习中

与[转帖]kafka指定topic设置消息留存时间相似的内容：

[转帖]kafka指定topic设置消息留存时间

背景单个主题消息量庞大，需要指定这个主题的消息留存时间缩小点执行命令 ./bin/kafka-configs.sh --bootstrap-server node1:9092 --entity-type topics --entity-name gaofengTest --alter --add

[转帖]Java 获取 Kafka 指定 topic 的消息总量

发表于 2020-11-29 分类于 Java ， Apache ， JavaClass ， Kafka Valine： 0 Kafka Consumer API Kafka 提供了两套 API 给 Consumer The high-level Consumer API The SimpleCon

[转帖]Kafka 核心技术与实战学习笔记（七）kafka集群参数配置（上）

一.Broker 端参数 Broke存储信息配置 log.dirs:非常重要，指定Broker需要使用的若干文件目录路径，没有默认值必须亲自指定。log.dir：他只能表示单个路径，补充上一个参数用。如何设置：只要设置log.dirs，不要设置log.dir线上环境一定要为log.dirs配置多

[转帖]Kafka—配置SASL/PLAIN认证客户端及常用操作命令

介绍 SASL/PLAIN 是一种简单的 username/password安全认证机制，本文主要总结服务端开启该认证后，命令行客户端进行配置的操作流程。配置增加jaas.properties 在kafka的config目录下增加jaas.properties文件指定认证协议为SASL_PLAI

[转帖]Kafka—配置SASL/PLAIN认证客户端及常用操作命令

介绍 SASL/PLAIN 是一种简单的 username/password安全认证机制，本文主要总结服务端开启该认证后，命令行客户端进行配置的操作流程。配置增加jaas.properties 在kafka的config目录下增加jaas.properties文件指定认证协议为SASL_PLAI

[转帖]使用jmx exporter采集kafka指标

https://www.cnblogs.com/charlieroro/p/16851629.html 预置条件安装kafka、prometheus 使用JMX exporter暴露指标下载jmx exporter以及配置文件。Jmx exporter中包含了kafka各个组件的指标，如serv

[转帖]Kafka 基本概念大全

https://my.oschina.net/jiagoushi/blog/5600943 下面给出 Kafka 一些重要概念，让大家对 Kafka 有个整体的认识和感知，后面还会详细的解析每一个概念的作用以及更深入的原理・Producer：消息生产者，向 Kafka Broker 发消息的客户端

[转帖]Kafka 与RocketMQ 落盘机制比较

https://www.jianshu.com/p/fd50befccfdd 引言前几期的评测中，我们对比了Kafka和RocketMQ的吞吐量和稳定性，本期我们要引入一个新的评测标准——软件可靠性。何为“可靠性”？先看下面这种情况：有A，B两辆越野汽车，在城市的周边地区均能很好应对泥泞的路况

[转帖]Kafka关键参数设置

https://www.cnblogs.com/wwcom123/p/11181680.html 生产环境中使用Kafka，参数调优非常重要，而Kafka参数众多，我们的java的Configuration代码中，经常设置的参数如下： Properties props = new Propertie

[转帖]kafka压测多维度分析实战

设置虚拟机不同的带宽来进行模拟压测 kafka数据压测 1、公司生产kafka集群硬盘：单台500G、共3台、日志保留7天。 1.1 版本：1.1.0 2、压测kafka。 2.1 使用kafka自带压测工具：bin/kafka-producer-perf-test.sh 命令参数解释： --num

# 热门排行

微软 New Bing AI 申请与使用保姆级教程（免魔法） ChatGPT API使用介绍 ChatGPT开发实战一篇带你了解如何使用纯前端类Excel表格构建现金流量表手把手教你玩转 Excel 数据透视表为什么 C# 可能是最好的第一编程语言 .NET 入门到高级路线提高工作效率的神器：基于前端表格实现Chrome Excel扩展插件 React + Springboot + Quartz，从0实现Excel报表自动化用Echarts实现前端表格引用从属关系可视化