当使用 MANUAL_IMMEDIATE 确认模式配合 DefaultErrorHandler 时，Kafka 消费容器默认会在消息成功恢复（如转发至死信主题）后自动提交偏移量，避免重复消费或消息丢失。
当使用 `manual_immediate` 确认模式配合 `defaulterrorhandler` 时，kafka 消费容器默认会在消息成功恢复（如转发至死信主题）后自动提交偏移量，避免重复消费或消息丢失。
在 Spring Kafka 中，当监听器配置为 ACKMODE=MANUAL_IMMEDIATE 时，开发者需显式调用 Acknowledgment.acknowledge() 才能提交偏移量。然而，若消息处理失败并交由 DefaultErrorHandler 处理（例如通过 DeadLetterPublishingRecoverer 转发至死信主题），是否需要手动确认该失败消息？答案是：通常不需要——容器已为你妥善处理。
自 Spring Kafka 2.5.3 起，DefaultErrorHandler 在成功执行恢复逻辑（即 recoverer.recover() 正常返回，未抛出新异常）后，会自动触发偏移量提交，即使 ACK 模式为 MANUAL_IMMEDIATE。这一行为由 setAckAfterHandle(true) 控制，默认即为 true。
✅ 正确做法：启用自动确认，无需额外干预
你只需确保 DefaultErrorHandler 的 ackAfterHandle 保持启用（默认即如此），即可实现“失败消息经恢复后安全提交偏移量”，从而杜绝重复消费与消息丢失：
BackOff fixedBackOff = new FixedBackOff(2000, 3);
DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(
kafkaTemplate,
(record, ex) -> new TopicPartition("OTHER-TOPIC", record.partition())
);
DefaultErrorHandler errorHandler = new DefaultErrorHandler(recoverer, fixedBackOff);
// ✅ 默认即为 true，显式设置更清晰（可选）
errorHandler.setAckAfterHandle(true); // ← 关键：允许容器在恢复后自动 ack
// 配置到 KafkaListenerContainerFactory 或 @KafkaListener 中
factory.setCommonErrorHandler(errorHandler);⚠️ 注意事项：
- 若
recoverer.recover()抛出异常（如网络失败导致死信发送失败），则DefaultErrorHandler将不提交偏移量，消息会按重试策略再次投递（符合 Exactly-Once 语义预期）； - 不要尝试在异常中“携带”
Acknowledgment对象——ListenerExecutionFailedException会包装原始异常，Acknowledgment无法穿透传递，且违背职责分离原则； - 已废弃的
setRecoveryCallback不再推荐使用，DeadLetterPublishingRecoverer+setAckAfterHandle是当前标准方案； - 若业务场景要求仅在特定条件下才提交偏移量（例如仅当死信写入成功且下游系统也确认后），需自定义
ErrorHandler并重写handle()方法，手动控制acknowledge()调用时机。
总结：Spring Kafka 的 DefaultErrorHandler 在 MANUAL_IMMEDIATE 模式下已内建偏移量安全机制。合理配置 DeadLetterPublishingRecoverer 并保留 ackAfterHandle=true（默认），即可在重试失败后将消息转入死信主题的同时，精准提交其偏移量——真正实现“不丢、不重、可追溯”的可靠消费。
