这家伙太懒,什么都没留下
是默认7天(10080小时),和清理时间一样。offsets.retention.minutes:当一个消费者组失去其消费者后(即为空),其offset在被丢弃前将被保留这个保留期。
offsets.retention.minutes
消费者组的offset,也存储在一个名为__consumer_offsets的主题里,同样的时间戳,也是基于这个进行清理的。
__consumer_offsets
可以去看看offsets.retention.minutes这个配置
offset不是指一条消息的下标吗,怎么会有有效时间呢?而且只有在消息需要压缩的时候,才会被合并,参考kafka日志压缩
一条消息是有时间戳的,基于这个进行清理的。
这个是日志保留时间,offset本身也有有效期,想知道offset的过期时间是多久
默认是保留7天,默认配置是config/server.properties中的
config/server.properties
log.retention.hours=168
删除的优先级可参考所有配置:Kafka Broker配置