diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
index df5ac31..03cd8b1 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
@@ -38,7 +38,7 @@ import java.util.concurrent.CompletableFuture;
 @RestController
 @RocketMQMessageListener(topic = "${rocketmq.consumer.analysisDify.topic}",consumerGroup = "${rocketmq.consumer.analysisDify.group}",
 		instanceName = "analysisDifyMqConsumer",
-		consumeThreadNumber = 1,
+		consumeThreadNumber = 20,
 		enableMsgTrace = true)
 public class AnalysisDifyMqConsumer implements RocketMQListener<MessageExt>  {