添加注释

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)

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<ConsumerRecord<String, Object>> recordMessages) {
 		long startTime = System.currentTimeMillis();

ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/TmTelephoneCorpusService.java

@@ -27,6 +27,4 @@ public interface TmTelephoneCorpusService extends IService<TmTelephoneCorpus> {
 
 	void sendMq(String tag, String message);
 
-
-	public String processChatSegments(String display, List<DataMaskingRule> maskingRuleItems);
 }