Kafka州商店Rock DB是容錯的,從更改日誌中可以如何恢復那些不起作用的數據?卡夫卡州商店Rock DB容錯?
回答
Kafka Streams API中所有內置存儲引擎的恢復都是完全自動的。
的進一步細節在http://docs.confluent.io/current/streams/developer-guide.html#fault-tolerant-state-stores描述,其中一些我在這裏引用:
爲了讓國營商店容錯(例如,從機器崩潰中恢復),以及允許狀態存儲在沒有數據丟失的情況下進行遷移(例如,在從應用程序彈性添加或刪除容量時,將有狀態的流任務從一臺機器遷移到另一臺機器),狀態存儲可以在後臺連續備份到卡夫卡主題。我們有時將此主題稱爲州商店的關聯變更日誌主題或簡稱其變更日誌。例如,在機器故障的情況下,狀態存儲器以及應用程序的狀態可以從其更新日誌中完全恢復。您可以爲狀態存儲啓用或禁用此備份功能,從而啓用或禁用其容錯功能。
因此,一個Kafka流程進程停止,所以其他Kafka流程進程將獲得相同的狀態存儲。哪個是自動化的,只需要啓用更改日誌 –
是的。並且默認情況下,更改日誌已啓用。 –
- 1. 卡夫卡國家商店忘記舊數據?
- 2. 卡夫卡經紀商 - 清潔關機
- 3. 卡夫卡生產商很慢
- 4. 卡夫卡批量生產商API
- 5. 卡夫卡customet partioner錯誤
- 6. 錯誤而卡夫卡
- 7. UnknownCodecException卡夫卡
- 8. 卡夫卡
- 9. 卡夫卡與斯卡拉
- 10. 卡夫卡Kubernetes/Minikube
- 11. 德魯伊卡夫卡攝取(暗示-2.2.3):卡夫卡錯誤NoReplicaOnlineException
- 12. 卡夫卡領導人選舉造成卡夫卡流崩潰
- 13. 卡夫卡的Zoopekeeper實例
- 14. 我應該使用什麼:卡夫卡流或卡夫卡消費者API或卡夫卡連接
- 15. 卡夫卡壺嘴配置錯誤
- 16. WSO2 EI611卡夫卡連接錯誤
- 17. 卡夫卡原生錯誤模式
- 18. kafka.common.FailedToSendMessageException:卡夫卡產生錯誤
- 19. 卡夫卡架構演變
- 20. 卡夫卡膠印管理
- 21. 卡夫卡的retention.ms沒有被卡夫卡0.10.2強制執行?
- 22. 卡夫卡:如何在卡夫卡實現循環分區
- 23. 卡夫卡連接或卡夫卡客戶
- 24. 春季卡夫卡表現vs本地卡夫卡api
- 25. 卡夫卡流和卡夫卡表一對多關係加入
- 26. 阿帕奇頂點 - 卡夫卡0.9安全卡夫卡主題
- 27. 如何從卡夫卡用卡夫卡流通過間隔
- 28. 卡夫卡0.9:消費從最早的卡夫卡偏移
- 29. 大卡夫卡消息VS小消息+ DB
- 30. 卡夫卡 - 性能測試
我不確定你的問題是什麼...... Kafka Streams會自動爲你恢復狀態。 –