spring-boot - 缩放消费者@StreamListener

Question

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

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

标签： spring-bootspring-cloudspring-cloud-streamspring-kafka

Answer 1

您应该能够通过spring.cloud.stream.bindings.input.consumer.concurrency消费者财产来实现这一目标。这里有更多信息