diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index 40c67fc..a96b667 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -229,6 +229,8 @@ public class DigestionTaskTheadManager {
                 "parameters", params
             );
             var messageJson = UfJsonHelper.objectToJson(message);
+            LOG.info("[DigestionTaskMqttMessage : (->)] Topic : {}; Payload : {}", transTopic, messageJson);
+
             MqttMessage mqttMessage = new MqttMessage(messageJson.getBytes());
             mqttMessage.setQos(2);
             this.client.publish(transTopic, mqttMessage);