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);
         // 执行耗时操作...
     }
 }