test

ibzdst-boot/src/main/resources/application-boot.yml

@@ -37,5 +37,4 @@ rocketmq:
     groupName: ${spring.application.name}
     namesrvAddr: 172.16.170.163:9876
     topics: DSTMSG~*
-    consumeThreadMin: 5
     consumeMessageBatchMaxSize: 1

ibzdst-core/src/main/java/cn/ibizlab/core/util/config/MQConsumerConfigure.java

@@ -25,9 +25,9 @@ public class MQConsumerConfigure {
     @Value("${rocketmq.consumer.topics:}")
     private String topics;
     // 消费者线程数据量
-    @Value("${rocketmq.consumer.consumeThreadMin: 5}")
+    @Value("${rocketmq.consumer.consumeThreadMin: 1}")
     private Integer consumeThreadMin;
-    @Value("${rocketmq.consumer.consumeThreadMax: 32}")
+    @Value("${rocketmq.consumer.consumeThreadMax: 1}")
     private Integer consumeThreadMax;
     @Value("${rocketmq.consumer.consumeMessageBatchMaxSize: 1}")
     private Integer consumeMessageBatchMaxSize;