admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

增加日志

Browse Source
This commit is contained in:
zren25
2025-03-31 13:52:02 +08:00
parent c9371875d5
commit 69298735f7
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaProducer.java
View File

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