Spring云流-并发

您可以显示您的配置吗?我刚刚测试了一下,它完全按照预期工作。。。

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

具有

@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) {

    }

}

和

立即,不发送任何消息