diff --git a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_rocketmq.erl b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_rocketmq.erl
index 205359bb8..67f2d2562 100644
--- a/lib-ee/emqx_ee_connector/src/emqx_ee_connector_rocketmq.erl
+++ b/lib-ee/emqx_ee_connector/src/emqx_ee_connector_rocketmq.erl
@@ -154,12 +154,15 @@ on_batch_query(_InstanceId, Query, _State) ->
 
 on_get_status(_InstanceId, #{client_id := ClientId}) ->
     case rocketmq_client_sup:find_client(ClientId) of
-        {ok, _Pid} ->
-            connected;
+        {ok, Pid} ->
+            status_result(rocketmq_client:get_status(Pid));
         _ ->
             connecting
     end.
 
+status_result(_Status = true) -> connected;
+status_result(_Status) -> connecting.
+
 %%========================================================================================
 %% Helper fns
 %%========================================================================================