Kafka状态存储Rock DB是容错的，从更改日志中如何恢复那段不起作用的数据？
Kafka Streams API 中所有内置存储引擎的恢复都是完全自动化的。
更多细节在 http://docs.confluent.io/current/streams/developer-guide.html#fault-tolerant-state-stores 中描述，其中一些我在这里引用：
为了使状态存储具有容错能力(例如，从计算机崩溃中恢复)，并允许在不丢失数据的情况下进行状态存储迁移(例如，在弹性添加或删除应用程序中的容量时将状态流任务从一台计算机迁移到另一台计算机)，可以在后台连续将状态存储备份到 Kafka 主题。我们有时将此主题称为状态存储的关联更改日志主题，或者简称为其更改日志。例如，在计算机发生故障的情况下，状态存储以及应用程序的状态可以从其更改日志中完全恢复。您可以为状态存储启用或禁用此备份功能，从而启用或禁用其容错能力。