使用spring-cloud-stream-binder-rocketmq如何设置多线程消费参数

[AI1186780944]

未在配置相关中找到可以设置consumeThreadMax和consumeThreadMin这两个参数的地方。我这边需要使用并行多线程消费消息，请问该如何处理

[DanielLiu1123]

配置该属性 org.springframework.cloud.stream.binder.ConsumerProperties#concurrency，会把 consumeThreadMax 和 consumeThreadMin 都设置为指定值

spring.cloud.stream.bindings.processor-in-0.consumer.concurrency=10

如果想要更灵活地配置 consumeThreadMax 和 consumeThreadMin，可以自己创建 DefaultMQPushConsumer

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(...);
consumer.setConsumeThreadMin(2);
consumer.setConsumeThreadMax(10);