diff --git a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
index ba2162993..05b9f7bf1 100644
--- a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
+++ b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_worker.erl
@@ -305,7 +305,7 @@ connected({call, From}, {send_to_remote, Msg}, State) ->
         {ok, NState} ->
             {keep_state, NState, [{reply, From, ok}]};
         {error, Reason} ->
-            {keep_state_and_data, [[reply, From, {error, Reason}]]}
+            {keep_state_and_data, {reply, From, {error, Reason}}}
     end;
 connected(cast, {send_to_remote_async, Msg, Callback}, State) ->
     _ = do_send_async(State, Msg, Callback),