Kafka中有两种“保留策略”:
一种是根据消息保留的时间,当消息在Kafka中保存的时间超过了指定时间,就可以被删除;
另一种是根据Topic存储的数据大小,当Topic所占的日志文件大小大于一个阈值,则可以开始删除最旧的消息。
Kafka会启动一个后台线程,定期检查是否存在可以删除的消息。
“保留策略”的配置是非常灵活的,可以有全局的配置,也可以针对Topic进行配置覆盖全局配置。