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 e02a9e4..3cc40ec 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
@@ -53,6 +53,9 @@ public class CorpusProcessKafkaProducer {
 			if(CollectionUtils.isNotEmpty(recordMessage)){
 				log.info("CorpusProcessKafkaProducer List size: {}", recordMessage.size());
 				for (ConsumerRecord<String, Object> record : recordMessage) {
+					log.info("CorpusProcessKafkaProducer List record.value: {}",record.value());
+					log.info("CorpusProcessKafkaProducer List record.key: {}",record.key());
+
 					executor.submit(() -> {
 						try {
 							String message = (String) record.value();