From 31af84f7da117744ab6b11551b0df8ad317a95fe Mon Sep 17 00:00:00 2001
From: ZLI263 <zhonghua.li.2@volvocars.com>
Date: Fri, 19 Sep 2025 12:16:58 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E9=AB=98=E6=B6=88=E8=B4=B9?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

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 9156f7b..2a7f14d 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
@@ -41,7 +41,7 @@ public class NameplateKafkaConsumer {
 	@Autowired
 	@Resource(name = "threadPoolTaskExecutor")
 	private ThreadPoolTaskExecutor executor;
-	private Semaphore semaphore = new Semaphore(10); // 限制并发数
+	private Semaphore semaphore = new Semaphore(2); // 限制并发数
 
 	@KafkaListener(topics = "${analyticCenterKafka.consumer.topic}",  // = smart_assistant_nameplate_topic
 			groupId = "${analyticCenterKafka.consumer.group}" , //smart_assistant_nameplate_topic_group
@@ -68,7 +68,11 @@ public class NameplateKafkaConsumer {
 			tmNameplateCorpus.getData().forEach(nameplate ->
 					CompletableFuture.runAsync(() -> {
 						try {
+							log.info(String.format("尝试获取许可，当前可用许可数: %d",
+									semaphore.availablePermits()));
 							semaphore.acquire(); // 获取许可
+							log.info(String.format("获取许可后，当前可用许可数:: %d",
+									semaphore.availablePermits()));
 							tmNameplateCorpusService.processItem(nameplate);
 						} catch (Exception e) {
 							log.error("corpusPortrait画像铭牌异步任务执行失败", e);