端到端的一致性保证,意味着结果的正确性贯穿了整个流处理应用的始终;每
一个组件都保证了它自己的一致性,整个端到端的一致性级别取决于所有组件中一
致性最弱的组件.
具体划分:
1.
内部保证 —— 依赖
checkpoint。
2.source
端 —— 需要外部源可重设数据的读取位置。
3.sink
端 —— 需要保证从故障恢复时,数据不会重复写入外部系统