From 674242c377d4c010a5363c73535d6b13e5ac9bc1 Mon Sep 17 00:00:00 2001
From: ama1 <anlun.ma.1@volvocars.com>
Date: Wed, 17 Sep 2025 17:19:10 +0800
Subject: [PATCH] Update NameplateKafkaConsumer.java

---
 .../com/volvo/ai/analytic/center/mq/NameplateKafkaConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 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 a05a5b4..b8773f3 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
@@ -37,7 +37,7 @@ public class NameplateKafkaConsumer {
 	@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) {