Spring Kafka阻塞重试实现失效，请求排查建议

使用Spring Boot Starter Parent 3.1.3版本，尝试基于Spring Kafka实现阻塞重试功能，编写了如下代码但功能未生效：

@Component
public class KafkaConsumer {
    private static final Logger log = LoggerFactory.getLogger(KafkaConsumer.class);

    @KafkaListener(
            id = "${messages.id}",
            groupId = "${messages.group.id}",
            topics = "${messages.topic}"
    )
    public void consumeEvent(String event) {
        processEvent(event);
    }

    private void processEvent(String event) {
        try {
            Long number = Long.parseLong(event);
            log.info("The number is {}", number);
        }
        catch (NumberFormatException ex) {
            throw new BlockingRetryException(ex.getMessage());
        }
    }
}

@EnableKafka
@Configuration
public class KafkaRetryConfiguration extends RetryTopicConfigurationSupport {

    @Override
    public void configureBlockingRetries(BlockingRetriesConfigurer blockingRetries) {
        blockingRetries
                .retryOn(BlockingRetryException.class)
                .backOff(new FixedBackOff(10000, 3));
    }

    @Override
    protected void configureCustomizers(CustomizersConfigurer customizersConfigurer) {
        customizersConfigurer.customizeErrorHandler(eh -> eh.setSeekAfterError(false));
    }

    @Bean
    public TaskScheduler taskScheduler() {
        return new ThreadPoolTaskScheduler();
    }
}

public class BlockingRetryException extends RuntimeException{
    public BlockingRetryException(String msg) {
        super(msg);
    }
}

以下是具体排查建议：

• 检查依赖版本兼容性：Spring Boot 3.1.3对应的Spring Kafka版本为3.0.8，确认项目pom.xml中Spring Kafka依赖是否继承自parent，未手动指定不兼容的版本。
• 验证异常传递链路：在抛出BlockingRetryException的位置添加日志，确认异常未被全局异常处理器提前捕获，能正常传递到Spring Kafka的错误处理逻辑中。
• 确认消费者offset配置：阻塞重试依赖offset不自动提交，需检查消费者配置：
  • enable.auto.commit是否设为false
  • Spring Kafka的AckMode是否配置为MANUAL或MANUAL_IMMEDIATE
• 检查TaskScheduler有效性：确保ThreadPoolTaskScheduler Bean被正确加载，可给Bean设置线程名称前缀（如((ThreadPoolTaskScheduler) taskScheduler).setThreadNamePrefix("kafka-retry-")），通过日志确认重试时是否有对应线程被调用。
• 绑定重试配置到目标消费者：尝试在configureBlockingRetries中明确指定目标主题或消费者，比如blockingRetries.forTopic("${messages.topic}")，确保配置覆盖到目标@KafkaListener。
• 开启DEBUG日志定位：添加日志配置logging.level.org.springframework.kafka=DEBUG，查看是否有重试逻辑触发的日志，定位配置未生效的环节。
• 确认异常类型匹配：检查抛出的异常是否确实是BlockingRetryException实例，未被包装为其他异常类型，确保retryOn配置的异常类型能匹配到实际抛出的异常。

内容的提问来源于stack exchange，提问作者Sk Monjurul Haque