Flink端到端一致性的保证（Flink到Kafka）-基于Paxos的Zab算法
有没有思考过这样的问题–在flink内部使用的分布式快照算法保证一致性的问题，那在flink运行的shangxiawen组件中一致性是怎么保证的呢？
flink内–checkpoint
实际生产中必须考虑端端一致性的保证，他的一致性级别取决于所有流程中一致性最弱的组件
预写日志：针对于非关系型数据库–如es redis等
两阶段提交：针对于关系型数据库
有没有思考过这样的问题–在flink内部使用的分布式快照算法保证一致性的问题，那在flink运行的shangxiawen组件中一致性是怎么保证的呢？
flink内–checkpoint
实际生产中必须考虑端端一致性的保证，他的一致性级别取决于所有流程中一致性最弱的组件
预写日志：针对于非关系型数据库–如es redis等
两阶段提交：针对于关系型数据库