source-flink-sink实现端到端的状态一致性

端到端（end-to-end）状态一致性 端到端的一致性保证，意味着结果的正确性贯穿了整个流处理应用的始终；每一个组件都保证了它自己的一致性，整个端到端的一致性级别取决于所有组件中一致性最弱的组件。具体可以划分如下： 内部保证 —— 依赖checkpoint source 端 —— 需要外部源可重设数据的读取位置（kafka/rocketmq） sink 端 —— 需要保证从故障恢复时，数据不会重

>>阅读原文<<