From 674242c377d4c010a5363c73535d6b13e5ac9bc1 Mon Sep 17 00:00:00 2001 From: ama1 Date: Wed, 17 Sep 2025 17:19:10 +0800 Subject: [PATCH 1/3] 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) { From 5e2ba20ad8adeaed084b289542b904043e0f26ce Mon Sep 17 00:00:00 2001 From: ama1 Date: Wed, 17 Sep 2025 20:46:38 +0800 Subject: [PATCH 2/3] fix sonar --- .../center/service/impl/DataMaskingRuleServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 Date: Wed, 17 Sep 2025 23:08:35 +0800 Subject: [PATCH 3/3] fix sonar --- .../ai/analytic/center/mq/NameplateKafkaConsumer.java | 7 ++++++- 1 file changed, 6 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 b8773f3..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,6 +34,10 @@ public class NameplateKafkaConsumer { @Autowired private TmNameplateCorpusService tmNameplateCorpusService; + @Value("${analyticCenterKafka.consumer.concurrency}") + private String concurrency; + + @KafkaListener(topics = "${analyticCenterKafka.consumer.topic}", groupId = "${analyticCenterKafka.consumer.group}" , @@ -42,7 +47,7 @@ public class NameplateKafkaConsumer { @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)) {