Spring-Kafka未调用acknowledge()时消息重消费机制及配置咨询

未调用acknowledge()时是否会重新消费未确认消息？ #

会重新消费。

结合你当前的配置和代码设置：

• spring.kafka.consumer.enable-auto-commit=false 关闭了自动提交，offset完全由手动调用acknowledge()控制
• AckMode设为MANUAL_IMMEDIATE，意味着只有调用acknowledge()才会立即提交当前消息的offset
• max-poll-records=1保证每次只拉取1条消息，并发数1是单线程处理

当你处理消息失败且未调用acknowledge()时，这条消息的offset不会被提交到Kafka集群。一旦消费者发生重启、重新平衡，或者在下一次poll操作时，会从最后一次成功提交的offset位置开始拉取消息，所以这条未确认的消息会被重新消费。

需要注意：如果消费者一直保持运行且没有触发重新平衡/重启，当前线程可能会卡在这条消息的处理逻辑里（比如死循环重试），不会主动去拉取下一条。这种情况下需要在代码里处理失败逻辑，比如抛出异常或者退出当前处理流程，让消费者能重新poll这条消息。

若不符合预期的配置调整 #

情况1：预期要重新消费但未生效 #

检查以下几点：

• 确认代码中确实没有调用acknowledge()，包括异常分支里是否误调用
• 检查消费者是否触发了重新平衡或重启：如果消费者一直运行没有重启/重平衡，且处理逻辑没有退出，可能不会主动重新拉取，需要在失败逻辑里加入退出机制（比如抛出RuntimeException，让Spring Kafka的监听容器重新处理）
• 确认spring.kafka.consumer.auto-offset-reset=earliest是生效的：不过这个配置主要是在消费者没有提交过offset时生效，已有提交offset的情况下，会以提交的offset为准

情况2：预期不想重新消费（即失败后跳过该消息） #

如果希望处理失败时直接跳过消息，不需要重新消费，可以：

• 在失败分支里主动调用acknowledge()，提交当前消息的offset，让消费者拉取下一条
• 或者在代码中捕获异常，记录日志后调用acknowledge()，避免重复消费

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