【Kafka】《Kafka權威指南》——提交和偏移量

KafkaConsumer(消費者)每次調用 poll()方法,它老是返回由生產者寫入 Kafka但尚未被消費者讀取過的記錄, 咱們因 此能夠追蹤到哪些記錄是被羣組裏的哪一個消費者讀取的。以前已經討論過, Kafka 不會像其餘 JMS 隊列那樣須要獲得消費者的確認,這是 Kafka 的一個獨特之處。相反,消 費者可使用 Kafka來追蹤消息在分區裏的位置(偏移量)。 咱們把更新分區當前位置的操做
相關文章
相關標籤/搜索