Spring Kafka消费者是否在poll循环内重试消息？关联max.poll.interval配置

核心机制说明 #

• 当消费者遇到可重试异常时，不会在当前poll循环内阻塞重试，而是会结束当前poll调用；后续再次调用poll时，Kafka会返回之前未处理成功的消息（因为这些消息的偏移量尚未提交）。
• 你的观察是准确的：触发可重试异常后，消费者会再次发起poll请求，且该请求会包含需要重试的消息。

对max.poll.interval.ms的影响 #

• 由于每次重试都依赖新的poll调用，max.poll.interval.ms的计时逻辑是从上次poll完成到下次poll开始的间隔。如果重试操作耗时过长，导致两次poll的间隔超过该阈值，Kafka集群会判定该消费者已失效，进而触发重平衡。
• 因此，你需要根据重试场景的最大可能耗时来调整max.poll.interval.ms的值，确保重试完成后能及时发起下一次poll，避免重平衡发生。

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