diff --git a/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_connector.erl b/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_connector.erl index 6afccccc0..4595358d7 100644 --- a/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_connector.erl +++ b/apps/emqx_bridge_gcp_pubsub/src/emqx_bridge_gcp_pubsub_connector.erl @@ -355,7 +355,7 @@ do_send_requests_sync(State, {prepared_request, {Method, Path, Body}}, ResourceI ), ?SLOG(error, #{ msg => "gcp_pubsub_error_response", - request => Request, + request => emqx_connector_http:redact_request(Request), connector => ResourceId, status_code => StatusCode }), @@ -371,9 +371,10 @@ do_send_requests_sync(State, {prepared_request, {Method, Path, Body}}, ResourceI ), ?SLOG(error, #{ msg => "gcp_pubsub_error_response", - request => Request, + request => emqx_connector_http:redact_request(Request), connector => ResourceId, - status_code => StatusCode + status_code => StatusCode, + resp_body => RespBody }), {error, #{status_code => StatusCode, headers => RespHeaders, body => RespBody}} end. diff --git a/apps/emqx_connector/src/emqx_connector_http.erl b/apps/emqx_connector/src/emqx_connector_http.erl index 149704f76..99381437c 100644 --- a/apps/emqx_connector/src/emqx_connector_http.erl +++ b/apps/emqx_connector/src/emqx_connector_http.erl @@ -42,6 +42,9 @@ namespace/0 ]). +%% for other webhook-like connectors. +-export([redact_request/1]). + -export([validate_method/1, join_paths/2]). -type connect_timeout() :: emqx_schema:duration() | infinity.