Apache Flink結合Kafka構建端到端的Exactly-Once處理

本文翻譯自：https://data-artisans.com/blog/end-to-end-exactly-once-processing-apache-flink-apache-kafka Apache Flink自2017年12月發佈的1.4.0版本開始，爲流計算引入了一個重要的里程碑特性：TwoPhaseCommitSinkFunction（相關的Jira）。它提取了兩階段提交協議的通用

>>阅读原文<<