Spring-Kafka 2.8.1中如何用DefaultErrorHandler替代已废弃的SeekToCurrentErrorHandler并禁用重试

首先，咱们来理清你遇到的问题：你已经定义了DefaultErrorHandler的Bean，但容器依然在使用默认的重试策略，这是因为Spring并不会自动把你定义的DefaultErrorHandlerBean绑定到Kafka监听容器工厂——你需要像之前使用SeekToCurrentErrorHandler那样，显式地把它设置到ConcurrentKafkaListenerContainerFactory中。

为什么之前的配置没生效？ #

你之前只单独创建了DefaultErrorHandler的Bean，但没有在kafkaListenerContainerFactory()中调用setErrorHandler()方法关联它。此时容器会使用默认的DefaultErrorHandler实例（默认重试次数为10次，也就是尝试10次后耗尽退避），这就是你日志里看到maxAttempts=9（重试9次，加上首次共10次）的原因。

正确的配置方式 #

要实现“发生错误时立即停止，不进行任何重试”的需求，推荐用两种方式配置：

方式1：直接在工厂中创建并设置DefaultErrorHandler

这种方式最直观，和你之前使用SeekToCurrentErrorHandler的逻辑一致：

@Bean 
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory() { 
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>(); 
    
    // 使用NoBackOffPolicy明确表示不进行任何重试
    DefaultErrorHandler errorHandler = new DefaultErrorHandler(new NoBackOffPolicy());
    
    // 或者用FixedBackOff(0L, 1)，效果相同：只执行1次尝试，无重试
    // DefaultErrorHandler errorHandler = new DefaultErrorHandler(new FixedBackOff(0L, 1));
    
    factory.setErrorHandler(errorHandler); 
    factory.setConsumerFactory(requestConsumerFactory()); 
    factory.setReplyTemplate(kafkaTemplate()); 
    return factory; 
}

方式2：单独定义DefaultErrorHandlerBean并注入工厂

如果你希望把ErrorHandler的配置独立出来，可以先定义Bean，再通过构造器注入到工厂中：

@Bean 
public DefaultErrorHandler defaultErrorHandler() { 
    // 用NoBackOffPolicy更清晰地表达“无重试”的意图
    return new DefaultErrorHandler(new NoBackOffPolicy());
}

@Bean 
public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> kafkaListenerContainerFactory(DefaultErrorHandler defaultErrorHandler) { 
    ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>(); 
    factory.setErrorHandler(defaultErrorHandler); // 显式绑定到工厂
    factory.setConsumerFactory(requestConsumerFactory()); 
    factory.setReplyTemplate(kafkaTemplate()); 
    return factory; 
}

额外补充：处理失败消息（可选） #

如果你希望把失败的消息转发到死信队列（DLQ），而不是直接丢弃，可以给DefaultErrorHandler添加DeadLetterPublishingRecoverer：

@Bean
public DefaultErrorHandler defaultErrorHandler(KafkaTemplate<String, String> kafkaTemplate) {
    // 配置死信转发器，默认会把失败消息发送到原topic后缀为".DLT"的队列
    DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(kafkaTemplate);
    return new DefaultErrorHandler(recoverer, new NoBackOffPolicy());
}

这样配置后，当消息处理失败时，会立即停止重试，并将消息转发到死信队列，方便后续排查问题。

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