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

有没有思考过这样的问题–在flink内部使用的分布式快照算法保证一致性的问题,那在flink运行的shangxiawen组件中一致性是怎么保证的呢? flink内–checkpoint 实际生产中必须考虑端端一致性的保证,他的一致性级别取决于所有流程中一致性最弱的组件 预写日志:针对于非关系型数据库–如es redis等 两阶段提交:针对于关系型数据库
相关文章
相关标签/搜索