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