阅读量:1
在Kafka中，可以通过设置log.retention.hours（以小时为单位）或log.retention.minutes（以分钟为单位）属性来配置消息保留策略
-
打开Kafka的配置文件
server.properties。这个文件通常位于Kafka安装目录的config文件夹中。 -
在
server.properties文件中，找到或添加以下配置项：log.retention.hours=168或者
log.retention.minutes=10080其中，
log.retention.hours表示消息保留的天数（168小时等于7天），log.retention.minutes表示消息保留的周数（10080分钟等于7天）。 -
保存并关闭
server.properties文件。 -
重启Kafka服务以使更改生效。具体操作取决于你的操作系统和Kafka安装方式。一般来说，可以使用以下命令重启Kafka服务：
sudo systemctl restart kafka或者
service kafka restart
现在，Kafka将按照指定的保留策略删除旧消息。请注意，这里的设置仅适用于Topic级别的消息保留。如果你需要为特定的Topic设置不同的保留策略，可以在创建Topic时通过log.retention.hours或log.retention.minutes属性进行设置。
以上就是关于“kafka properties如何设置消息保留策略”的相关介绍，筋斗云是国内较早的云主机应用的服务商，拥有10余年行业经验，提供丰富的云服务器、租用服务器等相关产品服务。云服务器资源弹性伸缩，主机vCPU、内存性能强悍、超高I/O速度、故障秒级恢复；电子化备案，提交快速，专业团队7×24小时服务支持！
简单好用、高性价比云服务器租用链接：https://www.jindouyun.cn/product/cvm