關於Kafka消費者中的偏移量的提交(Commits and Offsets)

關於Kafka消費者中的偏移量的提交 概述 KafkaConsumer API中多種提交偏移的方法 自動提交(Automatic Commit) 提交當前偏移量 異步提交(Asynchronous Commit) 結合同步和異步提交 提交指定的偏移量 參考資料 概述 每當咱們調用poll()時，它都會返回以前被寫入Kafka的記錄，即咱們組中的消費者尚未讀過的記錄。 這意味着咱們有一種方法能夠跟蹤

>>阅读原文<<