如果由于保留而导致节点崩溃和旧主题消息被丢弃,kafka流会失去状态吗?

xt0899hw  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(316)

默认情况下,kafka流使用rocksdb(一种快速本地kv存储)作为其状态存储。我的问题是,如果节点崩溃,并且那些要重放状态的主题消息由于kafka保留而被丢弃(因此它不能从一开始就重放消息),kafka流会失去状态吗?这是不是意味着在这种情况下那些旧的国家失去了?谢谢!

9bfwbjaz

9bfwbjaz1#

Kafka的“changelog topics”中的rocksdb存储。这些changelog主题配置为启用日志压缩。因此,国家是永远不会失去的。

相关问题