在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
属性进行设置。