diff --git a/apps/emqx_resource/src/emqx_resource_manager.erl b/apps/emqx_resource/src/emqx_resource_manager.erl
index be58bf0e0..c1adb8ecd 100644
--- a/apps/emqx_resource/src/emqx_resource_manager.erl
+++ b/apps/emqx_resource/src/emqx_resource_manager.erl
@@ -294,14 +294,11 @@ health_check(ResId) ->
 
 %% @doc Function called from the supervisor to actually start the server
 start_link(ResId, Group, ResourceType, Config, Opts) ->
-    QueryMode =
-        case erlang:function_exported(ResourceType, query_mode, 1) of
-            true ->
-                ResourceType:query_mode(Config);
-            false ->
-                maps:get(query_mode, Opts, sync)
-        end,
-
+    QueryMode = emqx_resource:query_mode(
+        ResourceType,
+        Config,
+        Opts
+    ),
     Data = #data{
         id = ResId,
         group = Group,