diff --git a/apps/emqx_mongodb/rebar.config b/apps/emqx_mongodb/rebar.config index 9cee51c35..b9390afc6 100644 --- a/apps/emqx_mongodb/rebar.config +++ b/apps/emqx_mongodb/rebar.config @@ -4,5 +4,5 @@ {deps, [ {emqx_connector, {path, "../../apps/emqx_connector"}}, {emqx_resource, {path, "../../apps/emqx_resource"}}, - {mongodb, {git, "https://github.com/emqx/mongodb-erlang", {tag, "v3.0.22"}}} + {mongodb, {git, "https://github.com/emqx/mongodb-erlang", {tag, "v3.0.23"}}} ]}. diff --git a/apps/emqx_mongodb/src/emqx_mongodb.app.src b/apps/emqx_mongodb/src/emqx_mongodb.app.src index e171d3dd2..92d7026cc 100644 --- a/apps/emqx_mongodb/src/emqx_mongodb.app.src +++ b/apps/emqx_mongodb/src/emqx_mongodb.app.src @@ -1,6 +1,6 @@ {application, emqx_mongodb, [ {description, "EMQX MongoDB Connector"}, - {vsn, "0.1.5"}, + {vsn, "0.1.6"}, {registered, []}, {applications, [ kernel, diff --git a/apps/emqx_mongodb/src/emqx_mongodb.erl b/apps/emqx_mongodb/src/emqx_mongodb.erl index 2c246e506..e959804cc 100644 --- a/apps/emqx_mongodb/src/emqx_mongodb.erl +++ b/apps/emqx_mongodb/src/emqx_mongodb.erl @@ -131,8 +131,8 @@ fields(topology) -> hoconsc:mk( pos_integer(), #{ - deprecated => {since, "5.1.1"}, - importance => ?IMPORTANCE_HIDDEN + importance => ?IMPORTANCE_HIDDEN, + default => 10 } )}, {max_overflow, fun max_overflow/1}, @@ -201,23 +201,7 @@ on_start( false -> [{ssl, false}] end, - Topology0 = maps:get(topology, NConfig, #{}), - %% we fix this at 1 because we already have ecpool - case maps:get(pool_size, Topology0, 1) =:= 1 of - true -> - ok; - false -> - ?SLOG( - info, - #{ - msg => "mongodb_overriding_topology_pool_size", - connector => InstId, - reason => "this option is deprecated; please set `pool_size' for the connector", - value => 1 - } - ) - end, - Topology = Topology0#{pool_size => 1}, + Topology = maps:get(topology, NConfig, #{}), Opts = [ {mongo_type, init_type(NConfig)}, {hosts, Hosts}, diff --git a/changes/ee/perf-12497.en.md b/changes/ee/perf-12497.en.md new file mode 100644 index 000000000..6c447caec --- /dev/null +++ b/changes/ee/perf-12497.en.md @@ -0,0 +1,3 @@ +Improve MongoDB connector performance. + +- [mongodb-erlang PR](https://github.com/emqx/mongodb-erlang/pull/41)