diff --git a/apps/iot/src/iot_mqtt_reply_subscriber.erl b/apps/iot/src/iot_mqtt_reply_subscriber.erl
index df04346..c7672ac 100644
--- a/apps/iot/src/iot_mqtt_reply_subscriber.erl
+++ b/apps/iot/src/iot_mqtt_reply_subscriber.erl
@@ -150,8 +150,7 @@ handle_info(Info, State = #state{}) ->
     State :: #state{}) -> term()).
 terminate(Reason, _State = #state{conn_pid = ConnPid}) when is_pid(ConnPid) ->
     %% 取消topic的订阅
-    TopicNames = lists:map(fun({Name, _}) -> Name end, ?Topics),
-    {ok, _Props, _ReasonCode} = emqtt:unsubscribe(ConnPid, #{}, TopicNames),
+    {ok, _Props, _ReasonCode} = emqtt:unsubscribe(ConnPid, #{}, ?Topic),
 
     ok = emqtt:disconnect(ConnPid),
     lager:debug("[iot_mqtt_reply_subscriber] terminate with reason: ~p", [Reason]),