diff --git a/apps/emqx_bridge/src/emqx_bridge_v2.erl b/apps/emqx_bridge/src/emqx_bridge_v2.erl index 7a2d112ab..fc70ee024 100644 --- a/apps/emqx_bridge/src/emqx_bridge_v2.erl +++ b/apps/emqx_bridge/src/emqx_bridge_v2.erl @@ -233,9 +233,13 @@ list_with_lookup_fun(LookupFun) -> fun(Name, _RawConf, Acc) -> [ begin - {ok, BridgeInfo} = - LookupFun(Type, Name), - BridgeInfo + case LookupFun(Type, Name) of + {ok, BridgeInfo} -> + BridgeInfo; + {error, not_bridge_v1_compatible} = Err -> + %% Filtered out by the caller + Err + end end | Acc ]