Spring Cloud Stream - Concurrency

Mahesh G

Using Spring Cloud Stream Version Chelsea.SR2, with RabbitMQ as message broker. To have multiple consumers we are using the property concurrency (The concurrency of the inbound consumer).
If we set concurrency as 50. It is starting with 1 and slowly it is increasing the consumers count. Is there any possible solution to start initial consumer Count with higher number instead of one to increase the consumer performance.

Gary Russell

Can you show your configuration? I just tested it and it worked exactly as expected...

spring.cloud.stream.bindings.input.group=foo
spring.cloud.stream.bindings.input.consumer.concurrency=10

with

@SpringBootApplication
@EnableBinding(Sink.class)
public class So48953227Application {

    public static void main(String[] args) {
        SpringApplication.run(So48953227Application.class, args);
    }

    @StreamListener(Sink.INPUT)
    public void listen(String in) {

    }

}

and

enter image description here

immediately, without sending any messages

Collected from the Internet

Please contact [email protected] to delete if infringement.

edited at
0

Comments

0 comments
Login to comment

Related