diff --git a/apps/emqx/priv/bpapi.versions b/apps/emqx/priv/bpapi.versions index 12fa9625e..91b01a4ee 100644 --- a/apps/emqx/priv/bpapi.versions +++ b/apps/emqx/priv/bpapi.versions @@ -13,6 +13,7 @@ {emqx_conf,1}. {emqx_conf,2}. {emqx_conf,3}. +{emqx_connector, 1}. {emqx_dashboard,1}. {emqx_delayed,1}. {emqx_delayed,2}. diff --git a/apps/emqx_connector/src/emqx_connector_api.erl b/apps/emqx_connector/src/emqx_connector_api.erl index f82e1741f..7b25ec204 100644 --- a/apps/emqx_connector/src/emqx_connector_api.erl +++ b/apps/emqx_connector/src/emqx_connector_api.erl @@ -744,7 +744,7 @@ do_bpapi_call(Node, Call, Args) -> do_bpapi_call_vsn(SupportedVersion, Call, Args) -> case lists:member(SupportedVersion, supported_versions(Call)) of true -> - apply(emqx_connector_proto_v4, Call, Args); + apply(emqx_connector_proto_v1, Call, Args); false -> {error, not_implemented} end. @@ -754,9 +754,7 @@ maybe_unwrap({error, not_implemented}) -> maybe_unwrap(RpcMulticallResult) -> emqx_rpc:unwrap_erpc(RpcMulticallResult). -supported_versions(start_connector_to_node) -> [2, 3, 4]; -supported_versions(start_connectors_to_all_nodes) -> [2, 3, 4]; -supported_versions(_Call) -> [1, 2, 3, 4]. +supported_versions(_Call) -> [1]. redact(Term) -> emqx_utils:redact(Term).