Kafka开启自动提交时，轮询触发后最大偏移量提交时机咨询

这个问题问得很戳痛点，不少刚上手Kafka消费者的同学都会搞混这个提交时机，我给你拆解清楚：

当你开启了自动提交功能，并且本次poll()调用满足自动提交间隔（也就是到了auto.commit.interval.ms设定的时间）时，偏移量是在读取新记录之前提交的，但要注意：提交的是上一次轮询返回的所有记录的最大偏移量，而非本次即将读取的记录偏移量。

给你举个直观的流程例子，帮你理解：

• 第一次调用poll()：消费者拉取到一批偏移量为0-99的记录，这时候因为是首次调用，还没到提交间隔，所以直接把这批记录返回给你处理，不做提交。
• 等过了auto.commit.interval.ms设定的时间后，你第二次调用poll()：
  1. 消费者先检查到已经满足提交间隔，立刻提交上一次拉取的记录的最大偏移量——也就是99；
  2. 完成提交后，才去Kafka集群拉取新的一批记录（比如偏移量100-199），再返回给你处理。

这里藏着一个需要注意的风险：自动提交的逻辑默认假设你已经处理完了上一批记录，但实际上它不管你有没有真的处理完——只要你再次调用poll()且满足间隔，就会提交上一批的偏移量。要是你在处理上一批记录的时候消费者崩溃了，那那些没处理完的记录就会因为偏移量已经提交而丢失，这也是为什么生产环境里很多人会选择手动提交偏移量的核心原因。

另外还有个细节：自动提交的触发完全绑定在poll()调用上，哪怕你处理上一批记录的耗时远超auto.commit.interval.ms，提交操作也只会等到你下一次调用poll()的时候才会执行，不会在处理过程中自动触发。

内容的提问来源于stack exchange，提问作者Manish