diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
index a05a5b4..c6a3cf0 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java
@@ -15,6 +15,7 @@ import org.springframework.kafka.support.KafkaHeaders;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.stereotype.Component;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.beans.factory.annotation.Value;
 
 /**
  * @ClassName NameplateKafkaConsumer
@@ -33,16 +34,20 @@ public class NameplateKafkaConsumer {
 	@Autowired
 	private TmNameplateCorpusService tmNameplateCorpusService;
 
+	@Value("${analyticCenterKafka.consumer.concurrency}")
+	private String concurrency;
+
+
 
 	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",
 			groupId = "${analyticCenterKafka.consumer.group}" ,
 			containerFactory = "analyticCenterConsumerFactory",
-			concurrency = "3")
+			concurrency = "${analyticCenterKafka.consumer.concurrency}")
 	public void listen(String recordMessages, Acknowledgment ack,
 					   @Header(KafkaHeaders.RECEIVED_PARTITION_ID) Integer partitionId,
 					   @Header(KafkaHeaders.OFFSET) Long offset) {
 		long startTime = System.currentTimeMillis();
-		log.info("nameplateKafkaConsumer 当前线程: {}, 线程ID: {},计数：{}", Thread.currentThread().getName(), Thread.currentThread().getId());
+		log.info("nameplateKafkaConsunameplateKafkaConsumermer 当前线程: {}, 线程ID: {},计数：{}", Thread.currentThread().getName(), Thread.currentThread().getId(),concurrency);
 		log.info("nameplateKafkaConsumerMessage: {}", recordMessages);
 		// 初始化绑定 Consumer
 		if (StringUtils.isEmpty(recordMessages)) {
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java
index 6ec258c..d80d84a 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/DataMaskingRuleServiceImpl.java
@@ -49,7 +49,7 @@ public class DataMaskingRuleServiceImpl extends ServiceImpl<DataMaskingRuleMappe
                         log.info("runMaskingRule categoryName:{} not support", ruleItem.getCategoryName());
                     }
                 } catch (Exception e) {
-                    e.printStackTrace();
+                    log.error("runMaskingRule errorMessage"+e.getMessage());
                 }
             }
         }