From cdca11f72fdb165d16e35356174836cdfbc34bf6 Mon Sep 17 00:00:00 2001 From: ZLI263 Date: Thu, 4 Sep 2025 16:03:09 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java | 4 ++-- .../ai/analytic/center/mq/CorpusProcessKafkaProducer.java | 2 ++ .../ai/analytic/center/service/TmTelephoneCorpusService.java | 2 -- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java index d583973..b409080 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusDccMqConsumer.java @@ -30,8 +30,8 @@ import java.util.Objects; @Component @RefreshScope @RestController -@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}", - topic = "${rocketmq.consumer.corpus.dcctopic}", +@RocketMQMessageListener(consumerGroup = "${rocketmq.consumer.corpus.dcctopicgroup}", //ai_corpus_Dcc_topic_group + topic = "${rocketmq.consumer.corpus.dcctopic}", //ai_corpus_Dcc_topic instanceName = "CorpusDccMqConsumer1", consumeThreadNumber = 40, enableMsgTrace = true) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java index db43838..fb2eeb9 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java @@ -47,6 +47,7 @@ public class CorpusProcessKafkaProducer { private final ObjectMapper objectMapper = new ObjectMapper(); + // ai_corpus_Dcc_topic @Value("${rocketmq.producer.corpus.dcctopic}") private String dccMqTipic; @@ -73,6 +74,7 @@ public class CorpusProcessKafkaProducer { // ), // groupId = "${spring.kafka.group}" // ) + //spring.kafka.topic=topic_voc_covert_text_log spring.kafka.group=topic_group_covert_text_log_voc_ai_ac_uat @KafkaListener(topics = "${spring.kafka.topic}", groupId = "${spring.kafka.group}") public void listen(List> recordMessages) { long startTime = System.currentTimeMillis(); diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmTelephoneCorpusService.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmTelephoneCorpusService.java index 45dea49..fe8af6a 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmTelephoneCorpusService.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmTelephoneCorpusService.java @@ -27,6 +27,4 @@ public interface TmTelephoneCorpusService extends IService { void sendMq(String tag, String message); - - public String processChatSegments(String display, List maskingRuleItems); } \ No newline at end of file