diff --git a/apps/emqx_bridge/src/emqx_bridge_api.erl b/apps/emqx_bridge/src/emqx_bridge_api.erl index 0f291ac1a..1358cccdc 100644 --- a/apps/emqx_bridge/src/emqx_bridge_api.erl +++ b/apps/emqx_bridge/src/emqx_bridge_api.erl @@ -431,8 +431,8 @@ rpc_multicall(Func, Args) -> end. filter_out_request_body(Conf) -> - ExtraConfs = [<<"id">>, <<"status">>, <<"node_status">>, <<"node_metrics">>, - <<"metrics">>, <<"node">>], + ExtraConfs = [<<"id">>, <<"status">>, <<"node_status">>, + <<"node_metrics">>, <<"metrics">>, <<"node">>], maps:without(ExtraConfs, Conf). rpc_call(Node, Fun, Args) -> diff --git a/apps/emqx_connector/src/emqx_connector_api.erl b/apps/emqx_connector/src/emqx_connector_api.erl index 5d6bddb6a..c20632658 100644 --- a/apps/emqx_connector/src/emqx_connector_api.erl +++ b/apps/emqx_connector/src/emqx_connector_api.erl @@ -218,7 +218,7 @@ schema("/connectors/:id") -> {400, error_msg('ALREADY_EXISTS', <<"connector already exists">>)}; {error, not_found} -> case emqx_connector:update(ConnType, ConnName, - maps:without([<<"type">>, <<"name">>], Params)) of + filter_out_request_body(Params)) of {ok, #{raw_config := RawConf}} -> Id = emqx_connector:connector_id(ConnType, ConnName), {201, format_resp(Id, RawConf)}; @@ -279,7 +279,7 @@ format_resp(ConnId, RawConf) -> }. filter_out_request_body(Conf) -> - ExtraConfs = [<<"num_of_bridges">>, <<"type">>, <<"name">>], + ExtraConfs = [<<"clientid">>, <<"num_of_bridges">>, <<"type">>, <<"name">>], maps:without(ExtraConfs, Conf). bin(S) when is_list(S) -> diff --git a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_schema.erl b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_schema.erl index 6fabb6b5d..bee1861bd 100644 --- a/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_schema.erl +++ b/apps/emqx_connector/src/mqtt/emqx_connector_mqtt_schema.erl @@ -39,7 +39,7 @@ fields("config") -> fields("connector") -> [ {mode, - sc(hoconsc:enum([cluster_singleton, cluster_shareload]), + sc(hoconsc:enum([cluster_shareload]), #{ default => cluster_shareload , desc => """ The mode of the MQTT Bridge. Can be one of 'cluster_singleton' or 'cluster_shareload'
@@ -76,10 +76,6 @@ topic filters for 'remote_topic' of ingress connections. #{ default => "emqx" , desc => "The password of the MQTT protocol" })} - , {clientid, - sc(binary(), - #{ desc => "The clientid of the MQTT protocol" - })} , {clean_start, sc(boolean(), #{ default => true