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)) {