Spring Cloud Stream Kafka Binder Leyton版本DLQ无消息问题排查

针对你遇到的DLQ无消息写入但错误处理器生效的问题，以下是几个可能的错误点及解决方法：

1. ErrorHandlingDeserializer未配置异常转发策略 #

你在report-in-0的消费者配置中使用了ErrorHandlingDeserializer，但默认情况下它只会记录异常并返回null，不会自动将消息发送到DLQ。需要添加配置让它将反序列化异常的消息转发到DLQ：

spring:
  cloud:
    stream:
      kafka:
        bindings:
          report-in-0:
            consumer:
              configuration:
                spring.deserializer.value.function: sendToDlq

这个配置会让ErrorHandlingDeserializer将反序列化失败的消息直接发送到你配置的DLQ主题。

2. DLQ生产者序列化配置缺失 #

损坏消息通常是原始字节格式，如果DLQ生产者没有配置合适的序列化器，可能导致消息无法发送。需要给DLQ添加生产者配置：

spring:
  cloud:
    stream:
      bindings:
        report-in-0:
          consumer:
            enableDlq: true
            dlqName: ${kafka-conf.report-dlq}
            dlqProducerProperties:
              configuration:
                key.serializer: org.apache.kafka.common.serialization.StringSerializer
                value.serializer: org.apache.kafka.common.serialization.ByteArraySerializer

使用ByteArraySerializer可以保证原始消息字节被正确发送到DLQ，避免二次序列化失败。

3. 变量解析异常 #

检查${kafka-conf.report-dlq}是否正确解析为report_dlq。可以查看应用启动日志，搜索dlqName相关内容，确认实际使用的DLQ主题名称是否正确。如果变量未正确解析，消息会被发送到错误的主题，自然无法在目标DLQ中找到。

4. 异常未触发DLQ拦截器 #

Stream的DLQ机制默认处理消费阶段抛出的异常，而ErrorHandlingDeserializer拦截了反序列化异常后，如果没有将异常抛出，Stream的DLQ拦截器就无法捕获。除了配置sendToDlq函数，也可以让ErrorHandlingDeserializer抛出异常：

spring.deserializer.value.throw-exception: true

这样异常会冒泡到Stream的DLQ拦截器，触发DLQ发送逻辑。

5. Kafka权限问题 #

确认当前应用使用的Kafka账号是否有向report_dlq主题发送消息的权限。如果没有权限，Kafka生产者会静默丢弃消息，不会有明显日志（除非开启org.apache.kafka的DEBUG级别日志）。可以通过Kafka管理工具检查主题的ACLs配置。

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