kafka保證數據只正確處理一次

kafka0.11.0.0版本正式支持精確一次處理語義(exactly onece semantic–EOS)。web EOS主要體如今3個方面： 一、冪等producer： 保證單個分區的只會發送一次，不會出現重複消息； 二、事務(transation)：保證原子性的寫入多個分區，即寫入到多個分區的消息要麼所有成功，要麼所有回滾； 三、流式EOS： 可當作是「 讀取-處理-寫入的管道 」。此ＥＯ

>>阅读原文<<