Flink端到端一致性的保證(Flink到Kafka)-基於Paxos的Zab算法

有沒有思考過這樣的問題–在flink內部使用的分佈式快照算法保證一致性的問題,那在flink運行的shangxiawen組件中一致性是怎麼保證的呢? flink內–checkpoint 實際生產中必須考慮端端一致性的保證,他的一致性級別取決於所有流程中一致性最弱的組件 預寫日誌:針對於非關係型數據庫–如es redis等 兩階段提交:針對於關係型數據庫
相關文章
相關標籤/搜索