From c0429ca333ddd7626dd3d00aa0774bad37ca7f09 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Wed, 24 Apr 2024 17:38:35 +0800 Subject: [PATCH] fix(plugin): refine schema serde log --- apps/emqx_plugins/src/emqx_plugins_serde.erl | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/apps/emqx_plugins/src/emqx_plugins_serde.erl b/apps/emqx_plugins/src/emqx_plugins_serde.erl index da8515390..5bc5aaa0c 100644 --- a/apps/emqx_plugins/src/emqx_plugins_serde.erl +++ b/apps/emqx_plugins/src/emqx_plugins_serde.erl @@ -62,16 +62,17 @@ lookup_serde(SchemaName) -> add_schema(Name, Avsc) -> case lookup_serde(Name) of {ok, _Serde} -> - ?SLOG(warning, #{msg => "plugin_avsc_schema_already_exists", name_vsn => Name}), + ?SLOG(warning, #{msg => "plugin_schema_already_exists", plugin => Name}), {error, already_exists}; {error, not_found} -> case gen_server:call(?MODULE, {build_serdes, to_bin(Name), Avsc}) of ok -> - ?SLOG(debug, #{msg => "plugin_avsc_schema_added", name_vsn => Name}), + ?SLOG(debug, #{msg => "plugin_schema_added", plugin => Name}), ok; {error, Reason} = E -> ?SLOG(error, #{ - msg => "plugin_avsc_schema_added_failed", + msg => "plugin_schema_add_failed", + plugin => Name, reason => emqx_utils:readable_error_msg(Reason) }), E