diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
index 47fd745..c5c4dd2 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java
@@ -33,7 +33,7 @@ import org.springframework.web.bind.annotation.RestController;
 @RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}",
 		topic = "${rocketmq.consumer.corpus.dcctopic}",
 		instanceName = "CorpusDccMqConsumer1",
-		consumeThreadNumber = 50,
+		consumeThreadNumber = 40,
 		enableMsgTrace = true)
 public class CorpusDccMqConsumer implements RocketMQListener<MessageExt>  {