diff --git a/src/main/java/com/ruoyi/device/domain/impl/djimqtt/service/DjiMqttClientService.java b/src/main/java/com/ruoyi/device/domain/impl/djimqtt/service/DjiMqttClientService.java
index d08d7c4..4b6503a 100644
--- a/src/main/java/com/ruoyi/device/domain/impl/djimqtt/service/DjiMqttClientService.java
+++ b/src/main/java/com/ruoyi/device/domain/impl/djimqtt/service/DjiMqttClientService.java
@@ -135,11 +135,11 @@ public class DjiMqttClientService {
             String topic = (String) message.getHeaders().get("mqtt_receivedTopic");
             String payload = (String) message.getPayload();
 
-            if (topic != null && payload != null) {
+            if (topic != null) {
                 messageHandler.handleMessage(topic, payload);
             }
         } catch (Exception e) {
-            log.error("MQTT客户端[{}]处理消息失败: ", config.getClientId(), e.getMessage(), e);
+            log.error("MQTT客户端[{}]处理消息失败: {}", config.getClientId(), e.getMessage(), e);
         }
     }