Spring Kafka自定义DefaultErrorHandler未生效，死信主题未创建问题排查

针对你遇到的自定义错误处理器未被采用、死信主题未创建的问题，按以下步骤逐一排查：

1. 确认容器工厂已绑定自定义ErrorHandler #

这是最常见的疏漏：仅定义了DefaultErrorHandler Bean，但未将其关联到你的byteArrayListenerContainerFactory中。

检查你的容器工厂配置，必须显式调用setErrorHandler()方法绑定自定义处理器：

@Bean
public ConcurrentKafkaListenerContainerFactory<String, byte[]> byteArrayListenerContainerFactory(
        ConsumerFactory<String, byte[]> byteArrayConsumerFactory,
        DefaultErrorHandler defaultErrorHandler) { // 注入自定义ErrorHandler
    ConcurrentKafkaListenerContainerFactory<String, byte[]> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConsumerFactory(byteArrayConsumerFactory);
    factory.setErrorHandler(defaultErrorHandler); // 关键：绑定错误处理器
    // 其他配置（如并发数、批量消费等）
    return factory;
}

2. 验证DefaultErrorHandler与DeadLetterPublishingRecoverer的配置正确性 #

确保你的错误处理器正确关联了重试策略和死信发布器，且自定义死信主题规则生效：

配置自定义死信主题解析器 #

@Bean
public DeadLetterPublishingRecoverer deadLetterPublishingRecoverer(ProducerFactory<Object, Object> producerFactory) {
    // 自定义死信主题规则：原主题后缀加"-dlq"，可根据需求修改
    DestinationResolver destinationResolver = (record, ex) -> {
        String dlqTopic = record.topic() + "-dlq";
        return new TopicPartition(dlqTopic, record.partition());
    };
    return new DeadLetterPublishingRecoverer(producerFactory, destinationResolver);
}

配置带重试策略的DefaultErrorHandler #

@Bean
public DefaultErrorHandler defaultErrorHandler(DeadLetterPublishingRecoverer recoverer) {
    // 配置重试：间隔1秒，最多重试3次（初始调用+3次重试，共4次执行）
    FixedBackOff fixedBackOff = new FixedBackOff(1000L, 3);
    DefaultErrorHandler errorHandler = new DefaultErrorHandler(recoverer, fixedBackOff);
    // 可选：指定哪些异常不重试，直接进入死信
    errorHandler.addNotRetryableException(IllegalArgumentException.class);
    return errorHandler;
}

3. 检查@KafkaListener的容器工厂指定是否正确 #

确认@KafkaListener注解的containerFactory属性值与你的自定义工厂Bean名称完全一致（注意大小写）：

@KafkaListener(topics = "your-topic", containerFactory = "byteArrayListenerContainerFactory")
public void listen(byte[] message) {
    // 模拟异常
    throw new RuntimeException("Test error");
}

4. 额外检查点 #

• 确保配置类上添加了@Configuration注解，保证所有Bean被Spring正确扫描并创建
• 若Kafka集群未开启auto.create.topics.enable，需手动创建死信主题；开启的情况下，死信主题会在第一条死信消息发送时自动创建
• 检查Spring Boot日志，确认自定义DefaultErrorHandler和容器工厂的Bean是否成功初始化（可搜索DefaultErrorHandler、byteArrayListenerContainerFactory关键词）

内容的提问来源于stack exchange，提问作者Higher-Kinded Type