此文章改编自Piotr Nowojski’s presentation from Flink Forward Berlin 2017，你可以从Flink Forward柏林站找到ppt和演讲录音。   Apache Flink 1.4.0发布于2017年12月，为流式处理引入了一个重要的里程碑：TwoPhaseCommitSinkFunction（相关jira单），通过将两阶段提交协议的通用逻辑进行抽取，使得使用Flink和包括kafka等一系列source，sink来开发端到端Exactly-Once的应用成为可能。它提供了一层抽象，用户只需要实现 […]