kafka如何保證訊息不丟失

a:消費端弄丟了資料

關閉自動提交offset，在自己處理完畢之後手動提交offset，這樣就不會丟失資料。

b:kafka弄丟了資料

一般要求設定4個引數來保證訊息不丟失：

①給topic設定replication.factor引數：這個值必須大於1，表示要求每個partition必須至少有2個副本。

②在kafka服務端設定min.isync.replicas引數：這個值必須大於1，表示要求乙個leader至少感知到有至少乙個follower在跟自己保持聯絡正常同步資料，這樣才能保證leader掛了之後還有乙個follower。

③在生產者端設定acks=all：表示要求每條每條資料，必須是寫入所有replica副本之後，才能認為是寫入成功了

④在生產者端設定retries=max(很大的乙個值，表示無限重試)：表示這個是要求一旦寫入事變，就無限重試

c：生產者弄丟了資料

如果按照上面設定了ack=all，則一定不會丟失資料，要求是，你的leader接收到訊息，所有的follower都同步到了訊息之後，才認為本次寫成功了。如果沒滿足這個條件，生產者會自動不斷的重試，重試無限次。