2017-04-05 47 views

回答

1

Kafka Streams API中所有內置存儲引擎的恢復都是完全自動的。

的進一步細節在http://docs.confluent.io/current/streams/developer-guide.html#fault-tolerant-state-stores描述,其中一些我在這裏引用:

爲了讓國營商店容錯(例如,從機器崩潰中恢復),以及允許狀態存儲在沒有數據丟失的情況下進行遷移(例如,在從應用程序彈性添加或刪除容量時,將有狀態的流任務從一臺機器遷移到另一臺機器),狀態存儲可以在後臺連續備份到卡夫卡主題。我們有時將此主題稱爲州商店的關聯變更日誌主題或簡稱其變更日誌。例如,在機器故障的情況下,狀態存儲器以及應用程序的狀態可以從其更新日誌中完全恢復。您可以爲狀態存儲啓用或禁用此備份功能,從而啓用或禁用其容錯功能。

+0

因此,一個Kafka流程進程停止,所以其他Kafka流程進程將獲得相同的狀態存儲。哪個是自動化的,只需要啓用更改日誌 –

+0

是的。並且默認情況下,更改日誌已啓用。 –