Kafka消費者手動提交消息偏移

生產者每次調用poll()方法時，它老是返回由生產者寫入Kafka但尚未消費的消息，若是消費者一致處於運行狀態，那麼分區消息偏移量就沒什麼用處，可是若是消費者發生崩潰或者有新的消費者加入羣組，就會觸發再均衡，完成再均衡以後，每一個消費可能分配到新的分區，而不是以前處理的那個，爲了可以繼續以前的工做，消費者須要讀取每一個分區最後一次提交的偏移量，而後從偏移量制定的地方開始工做。消費者會往一個__co

>>阅读原文<<