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<ConsumerRecord<String, Object>> 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<TmTelephoneCorpus> {
 
 	void sendMq(String tag, String message);
 
-
-	public String processChatSegments(String display, List<DataMaskingRule> maskingRuleItems);
 }
\ No newline at end of file