From 9fc695f93d5c1c9d77bfe0ea8981a573ec4cb7ea Mon Sep 17 00:00:00 2001 From: zren25 Date: Mon, 31 Mar 2025 21:15:13 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E9=AA=8C=E8=AF=81kafka?= =?UTF-8?q?=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/volvo/ai/analytic/center/mq/TestKafkaListener.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/TestKafkaListener.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/TestKafkaListener.java index 7e98c60..6d5918a 100644 --- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/TestKafkaListener.java +++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/TestKafkaListener.java @@ -1,5 +1,6 @@ package com.volvo.ai.analytic.center.mq; +import lombok.extern.slf4j.Slf4j; import org.apache.kafka.clients.consumer.*; import org.apache.kafka.common.PartitionInfo; import org.apache.kafka.common.TopicPartition; @@ -18,6 +19,7 @@ import java.util.Map; import java.util.Properties; import java.util.stream.Collectors; +@Slf4j @Component @RestController @RefreshScope @@ -61,7 +63,7 @@ public class TestKafkaListener { while(keepOnReading){ ConsumerRecords records = consumer.poll(Duration.ofMillis(100)); for (ConsumerRecord record : records){ - System.out.println(" testKakfa Message received " + record.value() + ", partition " + record.partition() + ", offset=" + record.offset() + ", timestamp=" + record.timestamp()); + log.info(" testKakfa Message received " + record.value() + ", partition " + record.partition() + ", offset=" + record.offset() + ", timestamp=" + record.timestamp()); } } }