Spring Cloud Stream集成RabbitMQ Streams报错求助

你的问题核心是RabbitMQ Stream插件使用独立的协议与专属端口，而非传统AMQP协议的5672端口。配置中spring.rabbitmq.stream.port设为5672，导致Stream客户端用AMQP端口连接Stream插件，协议不匹配，引发bad_header错误和超时异常。当切换为direct容器类型时，使用的是传统AMQP消费者，走5672端口，因此能正常运行，但并未用到RabbitMQ Stream插件的能力。

具体修正步骤 #

1. 修正Stream端口配置 #

将spring.rabbitmq.stream.port改为RabbitMQ Stream插件的默认端口5552（若自定义过端口则替换为对应值）：

spring:
  rabbitmq:
    listener:
      type: stream
    stream:
      host: ${RABBIT_HOST:localhost}
      port: ${RABBIT_STREAM_PORT:5552} # 修改此处为5552
      username: guest
      password: guest
      name: demo
  cloud:
    function:
      definition: testConsumer
    stream:
      rabbit:
        bindings:
          testConsumer-in-0:
            consumer:
              containerType: stream
      bindings:
        testConsumer-in-0:
          group: demo
          destination: test
        testProducer-out-0:
          destination: test

2. 确认RabbitMQ Stream插件已启用 #

确保你的RabbitMQ容器已启用Stream插件：

• 手动启用命令：

  rabbitmq-plugins enable rabbitmq_stream
  

• 容器启动时通过环境变量启用（以Docker为例）：

  docker run -d -p 5672:5672 -p 5552:5552 -e RABBITMQ_PLUGINS=rabbitmq_stream rabbitmq:3.11-management
  

3. 可选：生产者适配Stream协议（全链路Stream场景） #

如果需要生产者也通过Stream协议发送消息，需给生产者绑定添加containerType: stream配置：

spring:
  cloud:
    stream:
      rabbit:
        bindings:
          testConsumer-in-0:
            consumer:
              containerType: stream
          testProducer-out-0:
            producer:
              containerType: stream

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