kafka默認(rèn)使用at-least-once消息傳遞模式,at-least-once模式下,同一批次獲取N條數(shù)據(jù),這N條數(shù)據(jù)處理完,繼續(xù)獲取下一批數(shù)據(jù)時(shí),才會(huì)更新偏移量offset。

at-least-once
kafka默認(rèn)使用at-least-once消息傳遞模式,at-least-once模式下,同一批次獲取N條數(shù)據(jù),這N條數(shù)據(jù)處理完,繼續(xù)獲取下一批數(shù)據(jù)時(shí),才會(huì)更新偏移量offset。