kafka设置过期时间

消息的过期时间我们在使用Kafka存储消息时，如果已经消费过了，再永久存储是一种资源的浪费，所有，kafka为我们提供了消息文件的过期策略，可以通过配置server.properies来实现# vi config/server.properies修改下面的代码log.roll.hours=1log.retention.hours=2log.segment.delete.delay.ms=0重启ka

真恰噶噢

4383人浏览 · 2022-03-02 11:09:05

真恰噶噢 · 2022-03-02 11:09:05 发布

消息的过期时间

我们在使用Kafka存储消息时，如果已经消费过了，再永久存储是一种资源的浪费，所有，kafka为我们提供了消息文件的过期策略，可以通过配置server.properies来实现
# vi config/server.properies
修改下面的代码
log.roll.hours=1
log.retention.hours=2
log.segment.delete.delay.ms=0

重启kafka服务即可，上面表示消息存储时间为２小时。

设置单个topic的过期时间：

cleanup.policy=delete
file.delete.delay.ms=60000

retention.ms=86400000 为一天，单位是毫秒。
retention.ms=259200000 三天
retention.ms=172800000 2天