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

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