|
|
@@ -480,6 +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">>,
|
|
|
list_to_existing_atom(io_lib:format("~ts_~ts", [emqx_connector, DB])),
|
|
|
Config) of
|
|
|
{ok, already_created} ->
|