Spring-cloud-dataflow：如何默认使用 RabbitMQ 绑定器来创建仲裁队列

Question

我正在使用最新的 Spring Cloud Dataflow，使用 RabbitMQ 作为消息代理，并注意到从 http-source 和 log-sink 在 RabbitMQ 上创建的队列是经典队列。

我尝试将以下应用程序属性添加到流部署中，以将队列创建为仲裁队列，但它只是继续将它们创建为经典队列。

spring.cloud.stream.rabbit.default.quorum.enabled=true
spring.rabbitmq.default.quorum.enabled=true
spring.rabbitmq.quorum.enabled=true
rabbit.default.quorum.enabled=true

Answer 1

尝试直接正确设置绑定：

--spring.cloud.stream.rabbit.bindings.input.consumer.quorum.enabled=true

您还需要设置绑定组属性以创建命名队列（匿名无法与仲裁一起工作 - 请参阅https://github.com/spring-cloud/spring-cloud-stream/issues/2839 )