Spring Cloud Dataflow:如何默认让RabbitMQ绑定器创建仲裁队列
解决Spring Cloud Dataflow中RabbitMQ仲裁队列创建问题
你之前尝试的配置路径均不正确,Spring Cloud Stream RabbitMQ的仲裁队列配置需要针对具体的输入/输出绑定设置,而非全局默认前缀的配置项。
针对
http-source(消息输出源),需配置其输出绑定的生产者属性指定队列类型:# http-source默认输出绑定名为output spring.cloud.stream.bindings.output.producer.rabbit.queue-type=quorum针对
log-sink(消息消费端),需配置其输入绑定的消费者属性指定队列类型:# log-sink默认输入绑定名为input spring.cloud.stream.bindings.input.consumer.rabbit.queue-type=quorum若通过Spring Cloud Dataflow部署流,需为每个应用单独传递配置参数:
- 给
http-source添加参数:--spring.cloud.stream.bindings.output.producer.rabbit.queue-type=quorum - 给
log-sink添加参数:--spring.cloud.stream.bindings.input.consumer.rabbit.queue-type=quorum
- 给
补充:如果你的流定义中使用了非默认的绑定名称,需将上述配置里的
output/input替换为实际绑定名;同时确保RabbitMQ版本在3.8及以上(仲裁队列的最低支持版本)。
内容的提问来源于stack exchange,提问作者Stefan Du Preez
相关产品推荐
相关产品推荐

