Kafka state store Rock DB 是容错的吗?

Kafka state store Rock DB is fault tolerant?

Kafka 状态存储 Rock DB 是容错的,如何从更改日志中恢复那条不起作用的数据?

Kafka Streams API 中所有内置存储引擎的恢复是全自动的。

更多详细信息在 http://docs.confluent.io/current/streams/developer-guide.html#fault-tolerant-state-stores 中进行了描述,其中一些我在这里引用:

In order to make state stores fault-tolerant (e.g., to recover from machine crashes) as well as to allow for state store migration without data loss (e.g., to migrate a stateful stream task from one machine to another when elastically adding or removing capacity from your application), a state store can be continuously backed up to a Kafka topic behind the scenes. We sometimes refer to this topic as the state store’s associated changelog topic or simply its changelog. In the case of a machine failure, for example, the state store and thus the application’s state can be fully restored from its changelog. You can enable or disable this backup feature for a state store, and thus its fault tolerance.