Spring Kafka记录/批次处理判定及ackMode相关行为确认

从Spring Kafka文档中查到：
BATCH：当poll()返回的所有记录均处理完成后提交偏移量。
RECORD：当监听器处理完记录并返回后提交偏移量。

问题与解答 #

1. 如何判定记录或批次为「已处理」？是否指监听器接收消息且无错误完成处理？若中途因应用停止、异常等原因中断，是否会被判定为已处理？

• 「已处理」的核心判定标准是：监听器无异常完成单条记录（RECORD模式）或整个批次（BATCH模式）的业务逻辑处理，并正常返回。
• 若中途出现应用意外停止、抛出未捕获异常等中断场景，不会被判定为已处理。此时对应偏移量不会提交，应用重启后会从上次成功提交的偏移量位置，重新消费这些未处理完成的消息。

2. 若为非批量监听器设置ackMode = BATCH，会出现什么行为？是否会像ackMode = RECORD一样逐条提交偏移量？

• 非批量监听器（即接收单条ConsumerRecord或消息体的监听器）搭配ackMode = BATCH时，行为是：Kafka每次poll()拉取的一批记录会被逐条交给监听器处理，只有当这批所有记录都被无异常处理完成后，才会一次性提交整个批次的偏移量，并不会像RECORD模式那样逐条提交。
• 该行为完全符合Spring Kafka的设计预期：ackMode控制的是偏移量的提交时机，而非监听器接收消息的方式；非批量监听器仅负责单条处理消息，但提交逻辑仍遵循BATCH模式的规则——等当前poll批次的所有消息处理完毕后批量提交偏移量。

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