消费者如何不自动提交偏移量，由应用提交？

标签：sum   lse   for   col   family   mil   ott   margin   消费者   

将 auto.commit.offset 设为 false，然后在处理一批消息后 commitSync() 或者 

异步提交 commitAsync()

即：

ConsumerRecords<> records = consumer.poll();

for (ConsumerRecord<> record : records){

。。。

tyr{

consumer.commitSync()

}

。。。

}

消费者如何不自动提交偏移量，由应用提交？

标签：sum   lse   for   col   family   mil   ott   margin   消费者   

原文地址：https://www.cnblogs.com/programb/p/14056138.html