SpringBoot Kafka重试场景下DLT主题Schema兼容异常问题求助

一、DLT主题Schema为"bytes"的原因 #

• Spring Kafka默认的死信处理逻辑（如SeekToCurrentErrorHandler搭配DeadLetterPublishingRecoverer），在未指定DLT专属生产者配置时，会使用默认的字节序列化器发送死信消息。这会触发Schema Registry自动为DLT主题对应的Subject注册bytes类型的Schema。
• 当重试次数耗尽后，系统尝试将原本携带Avro Schema的消息发送到DLT时，由于DLT的Subject已存在bytes类型Schema，与待发送的Avro Schema结构不兼容，就会抛出RestIncompatibleSchemaException。

二、DeadLetterPublisher针对DLT的配置方法 #

要让DLT使用与主主题一致的Avro序列化规则，需要自定义DeadLetterPublishingRecoverer，为DLT指定专属的生产者配置：

1. 配置DLT专属生产者工厂
   创建一个独立的生产者工厂，指定Avro序列化器及Schema Registry地址（与主生产者配置保持一致）：

@Bean
public ProducerFactory<Object, Object> dltProducerFactory(KafkaProperties kafkaProperties) {
    Map<String, Object> configs = kafkaProperties.buildProducerProperties();
    // 替换为Avro序列化器
    configs.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
    configs.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, KafkaAvroSerializer.class);
    // 设置Schema Registry地址
    configs.put(AbstractKafkaAvroSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG, "http://your-schema-registry:8081");
    return new DefaultKafkaProducerFactory<>(configs);
}

2. 自定义死信恢复器
   将DLT生产者工厂传入，指定死信消息的目标主题：

@Bean
public ErrorHandler errorHandler(ProducerFactory<Object, Object> dltProducerFactory) {
    DeadLetterPublishingRecoverer recoverer = new DeadLetterPublishingRecoverer(
            dltProducerFactory,
            (record, exception) -> new TopicPartition("your-dlt-topic", -1)
    );
    // 这里的3是重试次数，可根据业务调整
    return new SeekToCurrentErrorHandler(recoverer, new FixedBackOff(1000L, 3L));
}

3. 关键注意事项

• 若DLT主题对应的Subject已注册bytes类型Schema，需先删除该Schema（或重新创建DLT主题），否则兼容异常仍会触发。
• 确保DLT生产者的Schema Registry配置与主生产者完全一致，保证Schema校验逻辑统一。

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