From 88799743d98da26f6088e9b65616d6aaaee5a59e Mon Sep 17 00:00:00 2001
From: wangli <274027703@qq.com>
Date: Thu, 21 Nov 2024 11:45:58 +0800
Subject: [PATCH] =?UTF-8?q?feat(REQ-3004)=20-=20=E7=A7=BB=E9=99=A4?=
 =?UTF-8?q?=E6=B5=8B=E8=AF=95=E6=97=B6=E7=9A=84=E7=BA=BF=E7=A8=8B=E9=99=90?=
 =?UTF-8?q?=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq/inside/consumer/ElasticSearchBatchSyncListener.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
index d5a1bcd5b..7cfc678b1 100644
--- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
+++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
@@ -60,8 +60,8 @@ public class ElasticSearchBatchSyncListener {
         consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
         consumer.subscribe(topic, "*");
         consumer.setConsumeMessageBatchMaxSize(refreshProperties.getEsSyncBatchSize());
-        consumer.setConsumeThreadMax(1);
-        consumer.setConsumeThreadMin(1);
+//        consumer.setConsumeThreadMax(1);
+//        consumer.setConsumeThreadMin(1);
         consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
             log.warn("batch get msg size: {}", msgs.size());
             if(CollectionUtils.isEmpty(msgs)) {