diff --git a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl index 727ea4ad8..111d0de7a 100644 --- a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl +++ b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb_connector.erl @@ -48,7 +48,7 @@ on_start(InstId, Config) -> on_stop(InstId, _State) -> case emqx_resource:get_allocated_resources(InstId) of - #{client := Client, producer := Producer} -> + #{?hstreamdb_client := #{client := Client, producer := Producer}} -> StopClientRes = hstreamdb:stop_client(Client), StopProducerRes = hstreamdb:stop_producer(Producer), ?SLOG(info, #{ diff --git a/changes/ee/fix-11627.en.md b/changes/ee/fix-11627.en.md new file mode 100644 index 000000000..8c0dd196f --- /dev/null +++ b/changes/ee/fix-11627.en.md @@ -0,0 +1,3 @@ +Fix resources cleanup in HStreamdB bridge. + +Prior to this fix, HStreamDB bridge might report errors during bridge configuration updates, since hstreamdb client/producer were not stopped properly.