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

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

>>阅读原文<<