modify consumer thread

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/rocketmq/consumer/ContentUnderstandingPipelineTaskConsumer.java

@@ -40,7 +40,7 @@ import java.util.Objects;
 @Component
 @RocketMQMessageListener(endpoints = "${rocketmq.consumer.endpoints:rmq-cn-vym47zv2i03-vpc.cn-hangzhou.rmq.aliyuncs.com:8080}",
         topic = "${rocketmq.consumer.pipelinetask.topic:topic_content_understanding_pipeline_task}",
-        consumerGroup = "${rocketmq.consumer.pipelinetask.group:group_content_understanding_pipeline_task}", tag = "*", consumptionThreadCount = 2)
+        consumerGroup = "${rocketmq.consumer.pipelinetask.group:group_content_understanding_pipeline_task}", tag = "*", consumptionThreadCount = 1)
 public class ContentUnderstandingPipelineTaskConsumer implements RocketMQListener {
 
     @Autowired

content-understanding-core/src/main/java/com/tzld/piaoquan/content/understanding/rocketmq/consumer/OldVersionRemainVideoUnderstandingConsumer.java

@@ -28,7 +28,7 @@ import java.util.Objects;
 @Component
 @RocketMQMessageListener(endpoints = "${rocketmq.consumer.endpoints:rmq-cn-vym47zv2i03-vpc.cn-hangzhou.rmq.aliyuncs.com:8080}",
         topic = "${rocketmq.consumer.oldversion.topic:topic_old_version_remain_video_understanding}",
-        consumerGroup = "${rocketmq.consumer.oldversion.group:group_old_version_remain_video_understanding}", tag = "*")
+        consumerGroup = "${rocketmq.consumer.oldversion.group:group_old_version_remain_video_understanding}", tag = "*", consumptionThreadCount = 1)
 public class OldVersionRemainVideoUnderstandingConsumer implements RocketMQListener {
 
     @Autowired