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 5f968f5..93a949b 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
@@ -39,8 +39,8 @@ public class NameplateKafkaConsumer {
 
 
 
-	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",
-			groupId = "${analyticCenterKafka.consumer.group}" ,
+	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",//= smart_assistant_nameplate_topic
+			groupId = "${analyticCenterKafka.consumer.group}" ,//smart_assistant_nameplate_topic_group
 			containerFactory = "analyticCenterConsumerFactory",
 			concurrency = "${analyticCenterKafka.consumer.concurrency}")
 	public void listen(String recordMessages, Acknowledgment ack,
@@ -56,8 +56,9 @@ public class NameplateKafkaConsumer {
 		}
 		try {
 			NameplateTableKafkaDTO tmNameplateCorpus = JSON.parseObject(recordMessages, NameplateTableKafkaDTO.class);
-			if (!"INSERT".equals(tmNameplateCorpus.getType()) || !"UPDATE".equals(tmNameplateCorpus.getType())  || CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
+			if ((!"INSERT".equals(tmNameplateCorpus.getType()) && !"UPDATE".equals(tmNameplateCorpus.getType()) )|| CollectionUtils.isEmpty(tmNameplateCorpus.getData())) {
 				ack.acknowledge();
+				log.info("nameplateKafkaConsumerMessage: 不符合预期的消息 {}", recordMessages);
 				return;
 			}
 
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
index 3901cd6..2b4fd61 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/TmNameplateCorpusServiceImpl.java
@@ -73,7 +73,10 @@ public class TmNameplateCorpusServiceImpl extends ServiceImpl<TmNameplateCorpusM
 	@Autowired
 	@Resource(name = "threadPoolTaskExecutor")
 	private ThreadPoolTaskExecutor executor;
-	private Semaphore semaphore = new Semaphore(6); // 限制并发数
+	@Value("${batch.threadNum}")
+	int  threadNum ;
+
+	private Semaphore semaphore = new Semaphore(threadNum); // 限制并发数
 
 	@Value("${dify.corpus.portrait.oneToken}")
 	private String oneTokenPortrait;