rabbitmq - 如何在自动缩放环境中使用 RabbitMQ 消费者设置 spring.cloud.stream.instanceCount？

Question

我正在使用 spring 云基础设施运行 RabbitMq 消费者。文档说明如下：

spring.cloud.stream.instanceCount
应用程序的已部署实例数。必须为生产者端的分区设置。如果 autoRebalanceEnabled=false，则在使用 RabbitMQ 和 Kafka时必须在消费者端设置。
默认值：1。
spring.cloud.stream.instanceIndex
应用程序的实例索引：一个从 0 到 instanceCount - 1 的数字。如果 autoRebalanceEnabled=false，则用于与 RabbitMQ 和 Kafka 进行分区。在 Cloud Foundry 中自动设置以匹配应用程序的实例索引。

我的消费者在自动扩展环境中运行 - 当队列超过阈值时，会引发更多消费者实例，而当它再次关闭时，一些消费者会关闭。

那么我应该如何定义这些参数呢？
它们真的是强制性的吗？

标签： rabbitmqspring-cloudspring-cloud-streamspring-rabbit

Answer 1

这些属性仅在使用分区队列时适用。

rabbitmq binder 在使用分区时不支持自动缩放。

只要您不使用分区，就可以忽略它们。