diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl
index eafe7cea6..d681c82c3 100644
--- a/apps/emqx_resource/src/emqx_resource_worker.erl
+++ b/apps/emqx_resource/src/emqx_resource_worker.erl
@@ -761,16 +761,6 @@ batch_reply_after_query(Pid, Id, Index, InflightTID, Ref, Batch, Result) ->
             ok
     end.
 
-ack_inflight_and_resume(Pid, InflightTID, Ref, Id, Index) ->
-    IsAcked = ack_inflight(InflightTID, Ref, Id, Index),
-    case is_inflight_full(InflightTID) of
-        true ->
-            ok;
-        false ->
-            ?MODULE:resume(Pid)
-    end,
-    IsAcked.
-
 %%==============================================================================
 %% operations for queue
 queue_item_marshaller(Bin) when is_binary(Bin) ->