kafka：如何保證消息不丟失不重複

首先要考慮這麼幾個問題： 消息丟失是什麼形成的？（從生產端和消費端兩個角度來考慮）緩存 消息重複是什麼形成的？（從生產端和消費端兩個角度來考慮）安全 如何保證消息有序？網絡 若是保證消息不重不漏，損失的是什麼？異步   下面是文章詳情，這裏先簡單總結一下： 消費端重複消費：很容易解決，創建去重表。async 消費端丟失數據：也容易解決，關閉自動提交offset，處理完以後受到移位。函數 生產端重複

>>阅读原文<<