Scaling consumers @StreamListener

Question

We're using spring cloud to serve asynchronous tasks. I wonder if there is any way to scale listeners set up by @StreamListener? The goal is to have multiple workers within one application instance.

I read about spring.cloud.stream.instancecount, but I don't want to replicate whole application, only increase workers count.

Answer 1

You should be able to accomplish that via spring.cloud.stream.bindings.input.consumer.concurrency consumer property. Here is more info