From f4c9861b4e846f4605bdf88d52fb764b92a6be8f Mon Sep 17 00:00:00 2001
From: eric <465889110@qq.com>
Date: Tue, 14 Oct 2025 23:39:40 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=B9=E4=B8=BA=E6=97=A5=E5=BF=97=E8=BE=93?=
 =?UTF-8?q?=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/sczx/sync/config/KafkaConsumer.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/sczx/sync/config/KafkaConsumer.java b/src/main/java/com/sczx/sync/config/KafkaConsumer.java
index 399f71c..4e5cf0a 100644
--- a/src/main/java/com/sczx/sync/config/KafkaConsumer.java
+++ b/src/main/java/com/sczx/sync/config/KafkaConsumer.java
@@ -1,9 +1,11 @@
 package com.sczx.sync.config;
 
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.stereotype.Component;
 import org.springframework.beans.factory.annotation.Autowired;
 
+@Slf4j
 @Component
 public class KafkaConsumer {
 
@@ -20,7 +22,8 @@ public class KafkaConsumer {
 
     private void processMessage(String message) {
         // 实际的消息处理逻辑
-        System.out.println("Processing message: " + message);
+
+        log.info("Received message: " + message);
         // 执行耗时操作...
     }
 }