Spring Boot 3.3.2中ConcurrentKafkaListenerContainerFactory无setRetryTemplate方法

是的，setRetryTemplate方法确实被移除了。Spring Kafka 3.0版本开始标记该方法为废弃，3.1版本（对应Spring Boot 3.3.x系列依赖的版本）彻底移除了这个方法，同时AbstractKafkaListenerContainerFactory也不再提供该方法。

替代方案：使用CommonErrorHandler（推荐DefaultErrorHandler）配置重试逻辑 #

目前Spring Kafka推荐通过CommonErrorHandler体系来处理消费重试及错误，DefaultErrorHandler是默认实现，可以结合RetryTemplate或直接内置配置来实现自定义重试策略。

方案1：结合自定义RetryTemplate配置

@Configuration
public class KafkaConsumerConfig {

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(
            ConsumerFactory<String, String> consumerFactory) {
        ConcurrentKafkaListenerContainerFactory<String, String> factory =
                new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory);

        // 构建自定义RetryTemplate
        RetryTemplate retryTemplate = new RetryTemplate();
        // 设置最大重试次数
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(3);
        retryTemplate.setRetryPolicy(retryPolicy);
        // 设置重试间隔（1秒）
        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(1000);
        retryTemplate.setBackOffPolicy(backOffPolicy);

        // 创建DefaultErrorHandler并关联RetryTemplate
        DefaultErrorHandler errorHandler = new DefaultErrorHandler(retryTemplate);
        // 指定哪些异常需要重试
        errorHandler.addRetryableExceptions(RemoteAccessException.class);
        // 指定哪些异常不重试
        errorHandler.addNotRetryableExceptions(IllegalArgumentException.class);

        // 将错误处理器绑定到容器工厂
        factory.setCommonErrorHandler(errorHandler);

        return factory;
    }
}

方案2：直接使用DefaultErrorHandler内置配置

如果不需要复杂的RetryTemplate逻辑，可以直接通过DefaultErrorHandler的构造参数快速配置重试：

@Configuration
public class KafkaConsumerConfig {

    @Bean
    public ConcurrentKafkaListenerContainerFactory<String, String> kafkaListenerContainerFactory(
            ConsumerFactory<String, String> consumerFactory) {
        ConcurrentKafkaListenerContainerFactory<String, String> factory =
                new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(consumerFactory);

        // 配置：重试间隔1秒，最多重试3次
        DefaultErrorHandler errorHandler = new DefaultErrorHandler(new FixedBackOff(1000, 3));
        // 添加重试/不重试的异常规则
        errorHandler.addRetryableExceptions(IOException.class);
        errorHandler.addNotRetryableExceptions(NullPointerException.class);

        factory.setCommonErrorHandler(errorHandler);

        return factory;
    }
}

核心原因 #

Spring Kafka移除setRetryTemplate是为了统一错误处理模型，CommonErrorHandler体系支持更丰富的错误处理场景，比如死信队列转发、异常分类处理、批量消费错误处理等，相比原有的RetryTemplate配置方式灵活性更强。

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