diff --git a/src/mqtt_client_wrapper.cpp b/src/mqtt_client_wrapper.cpp
index 2d8d03e..b2a5add 100644
--- a/src/mqtt_client_wrapper.cpp
+++ b/src/mqtt_client_wrapper.cpp
@@ -106,7 +106,7 @@ static void on_mqtt_message_received(const std::string &topic, const std::string
                 }
 
                 // 发送回复到 MQTT
-                mqtt_client.publish(g_app_config.mqtt.topics.video_up, reply.dump());
+                mqtt_client->publish(g_app_config.mqtt.topics.video_up, reply.dump(), 1);
                 LOG_INFO("[MQTT] Sent RTMP response: " + reply.dump());
             })
             .detach();