Kafka入門三:幾種消費方式

1.消費位移確認     Kafka消費者消費位移確認有自動提交與手動提交兩種策略。在建立KafkaConsumer對象時,經過參數enable.auto.commit設定,true表示自動提交(默認)。自動提交策略由消費者協調器(ConsumerCoordinator)每隔${auto.commit.interval.ms}毫秒執行一次偏移量的提交。手動提交須要由客戶端本身控制偏移量的提交。ja
相關文章
相關標籤/搜索