1

默认情况下,kafka 流使用 RocksDB(一种快速的本地 KV 存储)作为其状态存储。我的问题是,如果节点崩溃并且由于卡夫卡保留发生而丢弃那些重播状态的主题消息(所以它不能从一开始就重播消息),卡夫卡流会失去状态吗?这是否意味着在这种情况下失去了那些旧状态?谢谢!

4

1 回答 1

2

Kafka Streams在 Kafka 的“更改日志主题”中支持 RocksDB 存储。这些变更日志主题配置为启用了日志压缩。因此,状态永远不会丢失。

于 2018-03-18T06:33:16.217 回答