6.2. 消息保留


消息保留策略定义了信息存储在 Kafka 代理中的时长。它可根据时间、分区大小或两者定义。

例如,您可以定义应该保留的信息:

  • 7 天
  • 直到 parition 具有 1GB 的消息。达到限制后,会删除最旧的消息。
  • 7 天或直到达到 1GB 限制为止。将使用任何限制。
警告

Kafka 代理将信息存储在日志中。只有在创建新日志片段时,才会删除过去其保留策略的消息。当以前的日志片段超过配置的日志片段大小时,会创建新的日志片段。另外,用户可以要求定期请求创建新网段。

另外,Kafka 代理支持紧凑策略。

对于带有紧凑策略的主题,代理始终会仅为每个键保留最后一条消息。具有相同密钥的旧消息将从分区中删除。因为 compact 是一个定期执行的操作,所以当具有相同键的新消息发送到分区时不会立即发生。相反,可能需要稍等片刻,直到删除了旧消息。

有关消息保留配置选项的详情,请参考 第 6.5 节 “主题配置”

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。 了解我们当前的更新.

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

Theme

© 2025 Red Hat