Apache Flink結合Apache Kafka實現端到端的一致性語義

本次分享來自阿里巴巴的工程師在Apache Kafka x Apache Flink·北京會議上的分享,關於Apache Flink結合Apache Kafka實現端到端的一致性語義的原理。 2017年12月Apache Flink社區發佈了1.4版本。該版本正式引入了一個里程碑式的功能:兩階段提交Sink,即TwoPhaseCommitSinkFunction。 該SinkFunction提取並
相關文章
相關標籤/搜索