From f70fc1a3b027277caf5189d68aba6df5faa70cd3 Mon Sep 17 00:00:00 2001 From: EMQ-YangM Date: Wed, 16 Feb 2022 14:02:13 +0800 Subject: [PATCH] fix(emqx_bridge, emqx_retainer): hard code group name --- apps/emqx_bridge/src/emqx_bridge.erl | 3 +-- apps/emqx_retainer/src/emqx_retainer.erl | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/emqx_bridge/src/emqx_bridge.erl b/apps/emqx_bridge/src/emqx_bridge.erl index beb585c0c..446d87a6e 100644 --- a/apps/emqx_bridge/src/emqx_bridge.erl +++ b/apps/emqx_bridge/src/emqx_bridge.erl @@ -222,8 +222,7 @@ create(BridgeId, Conf) -> create(Type, Name, Conf) -> ?SLOG(info, #{msg => "create bridge", type => Type, name => Name, config => Conf}), - Group = maps:get(group, Conf, <<"default">>), - case emqx_resource:create_local(resource_id(Type, Name), Group, emqx_bridge:resource_type(Type), + case emqx_resource:create_local(resource_id(Type, Name), <<"emqx_bridge">>, emqx_bridge:resource_type(Type), parse_confs(Type, Name, Conf), #{async_create => true}) of {ok, already_created} -> maybe_disable_bridge(Type, Name, Conf); {ok, _} -> maybe_disable_bridge(Type, Name, Conf); diff --git a/apps/emqx_retainer/src/emqx_retainer.erl b/apps/emqx_retainer/src/emqx_retainer.erl index 69a598370..97333f022 100644 --- a/apps/emqx_retainer/src/emqx_retainer.erl +++ b/apps/emqx_retainer/src/emqx_retainer.erl @@ -480,7 +480,7 @@ create_resource(Context, #{type := DB} = Config) -> ResourceID = erlang:iolist_to_binary([io_lib:format("~ts_~ts", [?APP, DB])]), case emqx_resource:create( ResourceID, - <<"default">>, + <<"emqx_retainer">>, list_to_existing_atom(io_lib:format("~ts_~ts", [emqx_connector, DB])), Config) of {ok, already_created} ->