如何在Kubernetes+Strimzi环境下配置Kafka主题实现持久化存储？

核心配置说明 #

要让Kafka主题永久保留事件，需聚焦三个关键配置参数：

• retention.ms：设为-1，彻底禁用基于时间的消息自动删除（默认值为7天，即604800000）。
• retention.bytes：保持默认值-1，表示不限制主题存储的总消息大小，禁用基于容量的自动删除。
• cleanup.policy：保留默认的delete即可——compact模式针对键值对消息做压缩清理，而我们需要完整保留所有事件，delete配合无限时间/容量限制，就能实现事件永不自动删除。

你的假设是否正确？ #

完全正确。保留默认的cleanup.policy=delete和retention.bytes=-1，仅将retention.ms设为-1，确实能让主题内的事件永久保留，不会被Kafka自动清理。

验证你的配置示例 #

你提供的KafkaTopic配置是有效的，整理为更清晰的格式如下：

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
  labels:
    strimzi.io/cluster: my-kafka-cluster
  name: my-topic
spec:
  config:
    retention.ms: -1  # 禁用时间驱动的消息删除
    # cleanup.policy: delete  默认配置，无需显式声明
    # retention.bytes: -1     默认配置，无需显式声明
  partitions: 3
  replicas: 3

额外注意事项 #

• 虽然配置上实现了永久保留，但需确保Kafka集群的存储卷有足够容量——消息会持续累积，最终可能耗尽磁盘空间，建议监控存储使用率，必要时扩展存储或在业务允许的前提下手动清理历史数据。
• 后续如需调整保留策略，直接修改KafkaTopic资源的spec.config字段即可，Strimzi会自动将配置同步到Kafka集群，无需重启Broker。

内容的提问来源于stack exchange，提问作者Andreas