Kafka的冪等性與事務性理解

    最近在深入理解Flink的Exactly-Once，發現Flink Checkpoint只能保障Flink程序內部的一致性，無法保證Sink到外部系統的Exactly-Once語義。但是Sink到外部如果實現了TwoPhaseCommitSinkFunction這個抽象類就能實現端到端的Exactly-Once語義，而Kafka剛好也實現了這個這個類，所以先來研究下Kafka的Exactl

>>阅读原文<<