diff --git a/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java b/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
index 1d30483d..998695e2 100644
--- a/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
+++ b/fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
@@ -68,7 +68,7 @@ public class MqttMessageConsumer {
     public void consumeMessages() {
         String queueKey = MqttMessageQueueConstants.MQTT_MESSAGE_QUEUE_KEY;
         String threadName = Thread.currentThread().getName();
-        log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey);
+//        log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey);
         
         try {
             while (!Thread.currentThread().isInterrupted() && !messageConsumerPool.isShutdown()) {
@@ -81,7 +81,7 @@ public class MqttMessageConsumer {
                 );
                 
                 if (message != null) {
-                    log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message);
+//                    log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message);
                     // 将消息处理任务提交到处理线程池
                     messageProcessorPool.submit(() -> processMessage(message));
                 }