kafka之consumer參數auto.offset.reset

auto.offset.reset: 可理解爲kafka consumer讀取數據的策略,本地用的kafka版本爲0.10,因此該參數可填earliest|latest|none。 earliest: 當各分區下有已提交的offset時,從提交的offset開始消費;無提交的offset時,從頭開始消費 latest: 當各分區下有已提交的offset時,從提交的offset開始消費;無提交的of
相關文章
相關標籤/搜索