我们在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
1条答案
按热度按时间vuktfyat1#
如果你阅读了Apache文档中的这些设置,你会发现
retention.bytes
和retention.ms
依赖于使用delete
清理策略。将retention.bytes
保留为默认值(意味着没有大小限制,只有时间限制)意味着retention.ms
决定事件被保留的时间,并且你已经将该时间设置为none。