2017-04-05 76 views

回答

1

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

的进一步细节在http://docs.confluent.io/current/streams/developer-guide.html#fault-tolerant-state-stores描述,其中一些我在这里引用:

为了让国营商店容错(例如,从机器崩溃中恢复),以及允许状态存储在没有数据丢失的情况下进行迁移(例如,在从应用程序弹性添加或删除容量时,将有状态的流任务从一台机器迁移到另一台机器),状态存储可以在后台连续备份到卡夫卡主题。我们有时将此主题称为州商店的关联变更日志主题或简称其变更日志。例如,在机器故障的情况下,状态存储器以及应用程序的状态可以从其更新日志中完全恢复。您可以为状态存储启用或禁用此备份功能,从而启用或禁用其容错功能。

+0

因此,一个Kafka流程进程停止,所以其他Kafka流程进程将获得相同的状态存储。哪个是自动化的,只需要启用更改日志 –

+0

是的。并且默认情况下,更改日志已启用。 –