From 2a3aef92bb9cf0a8dc46522a79c10b4614a779e4 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Wed, 8 Mar 2023 09:35:17 -0300 Subject: [PATCH] refactor(kafka_consumer): redact error info --- .../src/kafka/emqx_bridge_impl_kafka_consumer.erl | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl b/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl index a38807f91..ab4a996bd 100644 --- a/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl +++ b/lib-ee/emqx_ee_bridge/src/kafka/emqx_bridge_impl_kafka_consumer.erl @@ -125,7 +125,7 @@ on_start(InstanceId, Config) -> msg => "failed_to_start_kafka_consumer_client", instance_id => InstanceId, kafka_hosts => BootstrapHosts, - reason => Reason + reason => emqx_misc:redact(Reason) }), throw(failed_to_start_kafka_client) end, @@ -312,7 +312,7 @@ start_subscriber(Config, InstanceId, ClientID) -> instance_id => InstanceId, kafka_hosts => emqx_bridge_impl_kafka:hosts(BootstrapHosts0), kafka_topic => KafkaTopic, - reason => Reason2 + reason => emqx_misc:redact(Reason2) }), stop_client(ClientID), throw(failed_to_start_kafka_consumer)