当 spring kafka 的非阻塞重试（如重试主题）因网络异常等原因发送失败时，系统默认启用阻塞式重试逻辑，并通过 seek 操作确保消息被重新消费，避免丢失。
当 spring kafka 的非阻塞重试（如重试主题）因网络异常等原因发送失败时，系统默认启用阻塞式重试逻辑，并通过 seek 操作确保消息被重新消费，避免丢失。
在使用 Spring Kafka 的 非阻塞重试机制（例如 @RetryableTopic）时，若消息因临时性故障（如 Broker 连接中断、磁盘满、ACL 拒绝等）无法成功发送至重试主题，KafkaListener 容器不会直接丢弃该消息，也不会静默失败。此时，框架会自动退回到阻塞式重试流程：即暂停当前消费者位点（offset）的提交，并触发 SeekToCurrentErrorHandler 的默认行为——对失败记录执行 seek() 操作，使其在下一轮 poll 中被重新拉取并再次处理。
这意味着：即使重试主题本身不可用，原始消息仍保留在原 topic-partition 中，且不会跳过或丢失。整个过程无需手动配置错误处理器，因为 Spring Kafka 2.8+ 默认启用了 SeekToCurrentErrorHandler（配合 DefaultAfterRollbackProcessor）。
✅ 示例配置（推荐显式声明以增强可维护性）：
@Bean
public DefaultKafkaConsumerFactory<?, ?> kafkaConsumerFactory() {
Map<String, Object> props = new HashMap<>(consumerConfigs());
return new DefaultKafkaConsumerFactory<>(props);
}
@Bean
public ConcurrentKafkaListenerContainerFactory<?, ?> kafkaListenerContainerFactory(
DefaultKafkaConsumerFactory<?, ?> consumerFactory) {
ConcurrentKafkaListenerContainerFactory<?, ?> factory = new ConcurrentKafkaListenerContainerFactory<>();
factory.setConsumerFactory(consumerFactory);
// 显式启用 seek-on-error 行为（默认已启用，此处仅为强调）
factory.setErrorHandler(new SeekToCurrentErrorHandler());
return factory;
}⚠️ 注意事项：
- SeekToCurrentErrorHandler 仅在同步处理上下文中生效（即 listener 方法未返回 ListenableFuture 或 CompletableFuture）；若使用异步非阻塞模式（如 @SendTo + @RetryableTopic），需确保重试主题的 Producer 配置具备足够鲁棒性（如 retries=2147483647、delivery.timeout.ms=120000），并配合 DeadLetterPublishingRecoverer 处理终极失败。
- 若需自定义失败降级策略（如写入数据库、告警、转存到本地文件），应继承 SeekToCurrentErrorHandler 并重写 handle() 方法，或替换为 CustomizableTraceableExceptionLogger + 自定义恢复器。
- 不建议完全禁用 seek 行为（如设置 ackOnError=false 且不配置 errorHandler），否则可能导致消息“幽灵丢失”。
总之，Spring Kafka 的重试链路具备天然的故障回退能力：非阻塞重试失败 → 自动降级为阻塞重试 → seek 保障消息不丢 → 最终由死信主题或自定义恢复器兜底。合理利用这一设计，可显著提升消息系统的弹性和可观测性。
