【七】kafka可靠性、有序性、重複消費、丟數據、線程安全

一、哪些情況會造成重複消費 1.生產者掛了重啓 場景: 生產者設置的ACK是ALL,及需要所有副本都保存了消息才叫發送成功。 假設生產者發送一條信息,leader已經收到且已經保存了,follower還沒來得及同步,leader就掛了。 此時會被認爲是發送失敗,重發。 而剛好重發的時候舊的leader又重啓復活了,那舊的leader會保存兩次同樣的數據 2.消費者自動提交偏移量 場景: 消費者A,
相關文章
相關標籤/搜索