深入解析Kafka消費者——提交和偏移量

KafkaConsumer(消費者)每次調用 poll()方法，它總是返回由生產者寫入 Kafka但還沒有被消費者讀取過的記錄， 我們因 此可以追蹤到哪些記錄是被羣組裏的哪個消費者讀取的。之前已經討論過， Kafka 不會像其他 JMS 隊列那樣需要得到消費者的確認，這是 Kafka 的一個獨特之處。相反，消 費者可以使用 Kafka來追蹤消息在分區裏的位置(偏移量)。 我們把更新分區當前位置的操

>>阅读原文<<