我的 Kafka 旅程 - Consumer( 二 ) _生活百科

# earliest：最早消費；無offset時，從頭開始消費。

# latest：最新消費；無offset時，從最新的數(shù)據(jù)開始消費。

# none：無offset時，引發(fā)異常。

auto.offset.reset = earliest | latest | none

消費現(xiàn)象重復消費：offset未提交成功，下次消費還是舊的offset 。
漏消費：offset提交成功，消費者端后續(xù)的數(shù)據(jù)處理未完成（建議下游步驟事務(wù)處理）。
消費者組為了實現(xiàn)橫向擴展，應(yīng)用程序需要創(chuàng)建一個消費者群組，然后往群組里添加消費者來提高處理效率，群組里的每個消費者只處理一部分消息。
消費者組是邏輯上的一個消費者，是由一個或多個消費者實例組成，具有可擴展性和可容錯性，消費者組內(nèi)的消費者共享一個GroupId組成；組內(nèi)每個消費者負責消費不同分區(qū)數(shù)據(jù)，并行消費數(shù)據(jù)；當組內(nèi)一個消費者掛了之后，其它消費者要自動承擔它的消費任務(wù) - 組內(nèi)再平衡。
觸發(fā)再平衡消費成員與Broker分區(qū)保持心跳連接，或者消費成員處理消息時間過長，會被認為此消費者需要被移除，觸發(fā)組內(nèi)消費成員任務(wù)再分配。以下配置任其一條件觸發(fā)再平衡：