auto.offset.reset值含義解釋

earliest

當(dāng)各分區(qū)下有已提交的offset時，從提交的offset開始消費(fèi)；無提交的offset時，從頭開始消費(fèi)

latest

當(dāng)各分區(qū)下有已提交的offset時，從提交的offset開始消費(fèi)；無提交的offset時，消費(fèi)新產(chǎn)生的該分區(qū)下的數(shù)據(jù)

none

topic各分區(qū)都存在已提交的offset時，從offset后開始消費(fèi)；只要有一個分區(qū)不存在已提交的offset，則拋出異常

默認(rèn)建議用earliest。設(shè)置該參數(shù)后 kafka出錯后重啟，找到未消費(fèi)的offset可以繼續(xù)消費(fèi)。

而latest 這個設(shè)置容易丟失消息，假如kafka出現(xiàn)問題，還有數(shù)據(jù)往topic中寫，這個時候重啟kafka，這個設(shè)置會從最新的offset開始消費(fèi),中間出問題的哪些就不管了。?

none這個設(shè)置沒有用過，兼容性太差，經(jīng)常出問題。