kafka 提供三種語義的傳遞：

               1至少一次

               2至多一次

               3精確一次

     首先在 producer 端保證1和2的語義是非常簡單的，至少一次只需要同步確認即可（確認方式分為只需要 leader 確認以及所有副本都確認，第二種更加具有容錯性），至多一次最簡單隻需要非同步不斷的傳送即可，效率也比較高。目前在 producer 端還不能保證精確一次，在未來有可能實現，實現方式如下：在同步確認的基礎上為每一條訊息加一個主鍵，如果發現主鍵曾經接受過，則丟棄。

     在 consumer 端，大家都知道可以控制 offset，所以可以控制消費，其實 offset 只有在重啟的時候才會用到。在機器正常執行時我們用的是 position，我們實時消費的位置也是 position 而不是 offset。我們可以得到每一條訊息的 position。如果我們在處理訊息之前就將當前訊息的 position 儲存到 zk 上即 offset，這就是隻多一次消費，因為我們可能儲存成功後，訊息還沒有消費機器就掛了，當機器再開啟時此訊息就丟失了；或者我們可以先消費訊息然後儲存 position 到 zk 上即 offset，此時我們就是至少一次，因為我們可能在消費完訊息後offset 沒有儲存成功。而精確一次的做法就是讓 position的儲存和訊息的消費成為原子性操作，比如將訊息和 position 同時儲存到 hdfs 上 ，此時儲存的 position 就稱為 offset，當機器重啟後，從 hdfs重新讀入offset，這就是精確一次。

---------------------------------------------------------------------------------

     以下為2017年10月27日更新：

截圖如下：