|
对于最新的稳定版本，请使用 spring-cloud-stream 4.3.0！ |
消费者群体
虽然发布-订阅模型使通过共享主题连接应用程序变得容易，但通过创建给定应用程序的多个实例来扩展的能力同样重要。 这样做时，应用程序的不同实例被放置在竞争的使用者关系中，其中只有一个实例需要处理给定的消息。
Spring Cloud Stream 通过消费者组的概念对这种行为进行建模。
（Spring Cloud Stream 消费者组与 Kafka 消费者组类似并受到其启发。
每个使用者绑定都可以使用spring.cloud.stream.bindings.<bindingName>.group属性来指定组名称。
对于下图所示的使用者，此属性将设置为spring.cloud.stream.bindings.<bindingName>.group=hdfsWrite或spring.cloud.stream.bindings.<bindingName>.group=average.
图 1.Spring Cloud Stream 消费者组
订阅给定目标的所有组都会收到已发布数据的副本，但每个组中只有一个成员从该目标接收给定消息。 默认情况下，当未指定组时，Spring Cloud Stream 会将应用程序分配给一个匿名且独立的单成员消费者组，该组与所有其他消费者组处于发布-订阅关系。