缩放消费者@StreamListener
Scaling consumers @StreamListener
我们正在使用 spring 云服务异步任务。我想知道是否有任何方法可以扩展 @StreamListener 设置的监听器？目标是在一个应用程序实例中拥有多个工作人员。
我读到 spring.cloud.stream.instancecount，但我不想复制整个应用程序，只增加工人数。
您应该可以通过 spring.cloud.stream.bindings.input.consumer.concurrency 消费者 属性 来实现。 Here is more info
我们正在使用 spring 云服务异步任务。我想知道是否有任何方法可以扩展 @StreamListener 设置的监听器？目标是在一个应用程序实例中拥有多个工作人员。
我读到 spring.cloud.stream.instancecount，但我不想复制整个应用程序，只增加工人数。
您应该可以通过 spring.cloud.stream.bindings.input.consumer.concurrency 消费者 属性 来实现。 Here is more info