From 69298735f703696ac7b3d459b26953d4ce026246 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Mon, 31 Mar 2025 13:52:02 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../ai/analytic/center/mq/CorpusProcessKafkaProducer.java      | 3 +++
 1 file changed, 3 insertions(+)

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();