kafka同步異步消費和消息的偏移量（四）

1. 消費者位置(consumer position) 由於kafka服務端不保存消息的狀態，因此消費端須要本身去作不少事情。咱們每次調用poll()方法他老是返回已經保存在生產者隊列中還未被消費者消費的消息。消息在每個分區中都是順序的，那麼必然能夠經過一個偏移量去肯定每一條消息的位置。web 偏移量在消費消息的過程當中處於重要的做用。若是是自動提交消息，那麼poll()方法會去在每次獲取消息的時

>>阅读原文<<