7.2. 消息保留
消息保留策略定义信息在 Kafka 代理中存储的时长。它可根据时间、分区大小或两者来定义。
例如,您可以定义信息应保留:
- 7 天
- 直到 parition 具有 1GB 消息。达到限制后,将删除最旧的消息。
- 达到 7 天或直到达到 1GB 限值为止。任何限制最先使用。
警告
Kafka 代理将信息存储在日志片段中。只有在创建新日志段时,才会删除过去其保留策略的消息。当以前的日志片段超过配置的日志片段大小时,会创建新的日志片段。另外,用户可以请求定期创建新段。
另外,Kafka 代理支持紧凑策略。
对于压缩策略的主题,代理将始终只保留每个密钥的最后一个消息。具有相同密钥的旧消息将从分区中删除。因为 compact 是一个定期执行的操作,所以当具有相同键的新消息发送到分区时不会立即发生。相反,可能需要稍等片刻,直到旧的消息被删除为止。
有关消息保留配置选项的详情请参考 第 7.5 节 “主题配置”。