diff --git a/apps/emqx_resource/src/emqx_resource_manager.erl b/apps/emqx_resource/src/emqx_resource_manager.erl index 288083172..ec6165f85 100644 --- a/apps/emqx_resource/src/emqx_resource_manager.erl +++ b/apps/emqx_resource/src/emqx_resource_manager.erl @@ -147,9 +147,9 @@ create(ResId, Group, ResourceType, Config, Opts) -> QueryMode = emqx_resource:query_mode(ResourceType, Config, Opts), case QueryMode of %% the resource has built-in buffer, so there is no need for resource workers - simple_sync -> + simple_sync_internal_buffer -> ok; - simple_async -> + simple_async_internal_buffer -> ok; %% The resource is a consumer resource, so there is no need for resource workers no_queries ->