将 auto.commit.offset 设为 false,然后在处理一批消息后 commitSync() 或者
异步提交 commitAsync()
即:
ConsumerRecords<> records = consumer.poll();
for (ConsumerRecord<> record : records){
。。。
tyr{
consumer.commitSync()
}