Spring Cloud Stream RabbitMQ Binder的republishToDlq不生效如何解决

问题根源 #

你遇到的警告和功能不生效的核心是两点配置错误：

1. republishToDlq是Rabbit Binder专属的扩展属性，不属于Spring Cloud Stream通用的Binding消费者配置，你当前将该配置放在通用spring.cloud.stream.bindings.<binding-name>.consumer节点下无法被Rabbit Binder识别。
2. 启用republishToDlq功能时，Binder需要自动创建一个专用的死信交换器（DLX）用于转发异常消息，你当前的配置缺少Rabbit专属的自动声明规则，导致DLX不存在，republishToDlq被自动禁用。你当前看到的DLQ是Rabbit原生死信机制生成的，由Broker直接路由消息，不会附加应用层的异常堆栈信息。

解决方案 #

调整配置结构，将Rabbit专属的DLQ相关配置移到Rabbit Binder专属的配置节点下，参考正确配置如下：

spring:
  main:
    web-application-type: none
  cloud:
    stream:      
      bindings:
        consumeSomething-in-0:
          destination: some-topic-vhost2
          group: some-events
          binder: local_rabbit
          consumer:
            max-attempts: 1
      # Rabbit Binder专属配置节点
      rabbit:
        bindings:
          consumeSomething-in-0:
            consumer:
              auto-bind-dlq: true
              dlq-ttl: 50000
              republish-to-dlq: true

调整后请确认你的应用使用的RabbitMQ账号具备交换器、队列的创建权限，重启应用后警告会消失，消费失败的消息会由应用侧重新发布到DLQ，消息头会自动携带x-exception-stacktrace等异常相关信息。

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