默认情况下,kafka流使用rocksdb(一种快速本地kv存储)作为其状态存储。我的问题是,如果节点崩溃,并且那些要重放状态的主题消息由于kafka保留而被丢弃(因此它不能从一开始就重放消息),kafka流会失去状态吗?这是不是意味着在这种情况下那些旧的国家失去了?谢谢!
9bfwbjaz1#
Kafka的“changelog topics”中的rocksdb存储。这些changelog主题配置为启用日志压缩。因此,国家是永远不会失去的。
1条答案
按热度按时间9bfwbjaz1#
Kafka的“changelog topics”中的rocksdb存储。这些changelog主题配置为启用日志压缩。因此,国家是永远不会失去的。