缩放消费者@StreamListener

【问题标题】：Scaling consumers @StreamListener缩放消费者@StreamListener
【发布时间】：2019-09-07 15:18:52
【问题描述】：

我们使用 Spring Cloud 来处理异步任务。我想知道是否有任何方法可以扩展@StreamListener 设置的听众？目标是在一个应用程序实例中拥有多个工作人员。

我读到了spring.cloud.stream.instancecount，但我不想复制整个应用程序，只想增加工作人员数量。

【问题讨论】：

【解决方案1】：

您应该能够通过 spring.cloud.stream.bindings.input.consumer.concurrency 消费者属性来实现这一点。 Here is more info

【讨论】：

如果您使用的是 Kafka binder，则至少需要多个分区，如 concurrency，因为每个分区只能有一个使用者。
如果我没有那么多分区怎么办？而只是想增加工人。有可能吗？
有效！我不得不将springCloudVersion = 'Greenwich.M1' 更改为springCloudVersion = 'Greenwich.RELEASE'