如果我想把Kafka当作一个持久的事件存储,我该如何配置我的主题?

yqlxgs2m  于 2023-03-01  发布在  Apache
关注(0)|答案(1)|浏览(118)

我们在Kubernetes上使用Apache Kafka和Strimzi,如果我们想把Kafka当作一个持久的事件存储器(无限期地保存事件),我应该如何配置我的主题?
如果我们保留默认的cleanup.policy(删除)和retention.bytes(-1),并将www.example.com设置retention.ms为-1,那么这些事件永远不会被删除,我的假设是否正确?

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaTopic
metadata:
  labels:
    strimzi.io/cluster: my-kafka-cluster
  name: my-topic
spec:
  config:
    # cleanup.policy: delete -> default
    # retention.bytes: -1 -> default 
    retention.ms: -1
  partitions: 3
  replicas: 3
vuktfyat

vuktfyat1#

如果你阅读了Apache文档中的这些设置,你会发现retention.bytesretention.ms依赖于使用delete清理策略。将retention.bytes保留为默认值(意味着没有大小限制,只有时间限制)意味着retention.ms决定事件被保留的时间,并且你已经将该时间设置为none。

相关问题