關於Kafka冪等producer的討論

衆所周知，Kafka 0.11.0.0版本正式支持精確一次處理語義(exactly once semantics，下稱EOS)。Kafka的EOS主要體現在3個方面： 冪等producer：保證發送單個分區的消息只會發送一次，不會出現重複消息 事務(transaction)：保證原子性地寫入到多個分區，即寫入到多個分區的消息要麼全部成功，要麼全部回滾 流處理EOS：流處理本質上可看成是「讀取-處理

>>阅读原文<<