diff --git a/apps/emqx/src/emqx_access_control.erl b/apps/emqx/src/emqx_access_control.erl index b786e2c18..13b02bb4d 100644 --- a/apps/emqx/src/emqx_access_control.erl +++ b/apps/emqx/src/emqx_access_control.erl @@ -184,7 +184,7 @@ log_result(#{username := Username}, Topic, Action, From, Result) -> end, case Result of allow -> ?SLOG(info, (LogMeta())#{msg => "authorization_permission_allowed"}); - deny -> ?SLOG(warning, (LogMeta())#{msg => "authorization_permission_denied"}) + deny -> ?SLOG(info, (LogMeta())#{msg => "authorization_permission_denied"}) end. %% @private Format authorization rules source. diff --git a/apps/emqx/src/emqx_channel.erl b/apps/emqx/src/emqx_channel.erl index bb9c84e8c..2ffe880f3 100644 --- a/apps/emqx/src/emqx_channel.erl +++ b/apps/emqx/src/emqx_channel.erl @@ -613,7 +613,7 @@ process_publish(Packet = ?PUBLISH_PACKET(QoS, Topic, PacketId), Channel) -> do_publish(PacketId, Msg, NChannel); {error, Rc = ?RC_NOT_AUTHORIZED, NChannel} -> ?SLOG( - warning, + info, #{ msg => "cannot_publish_to_topic", reason => emqx_reason_codes:name(Rc) @@ -632,7 +632,7 @@ process_publish(Packet = ?PUBLISH_PACKET(QoS, Topic, PacketId), Channel) -> end; {error, Rc = ?RC_QUOTA_EXCEEDED, NChannel} -> ?SLOG( - warning, + info, #{ msg => "cannot_publish_to_topic", reason => emqx_reason_codes:name(Rc) diff --git a/apps/emqx/src/emqx_session_events.erl b/apps/emqx/src/emqx_session_events.erl index f46144020..856efac74 100644 --- a/apps/emqx/src/emqx_session_events.erl +++ b/apps/emqx/src/emqx_session_events.erl @@ -63,7 +63,7 @@ handle_event(ClientInfo, {dropped, Msg, #{reason := queue_full, logctx := Ctx}}) ok = inc_pd('send_msg.dropped', 1), ok = inc_pd('send_msg.dropped.queue_full', 1), ?SLOG( - warning, + info, Ctx#{ msg => "dropped_msg_due_to_mqueue_is_full", payload => Msg#message.payload diff --git a/apps/emqx_license/src/emqx_license.erl b/apps/emqx_license/src/emqx_license.erl index eaa9661e3..c0fc10b91 100644 --- a/apps/emqx_license/src/emqx_license.erl +++ b/apps/emqx_license/src/emqx_license.erl @@ -85,7 +85,7 @@ check(_ConnInfo, AckProps) -> {ok, #{max_connections := MaxClients}} -> case check_max_clients_exceeded(MaxClients) of true -> - ?SLOG(error, #{msg => "connection_rejected_due_to_license_limit_reached"}), + ?SLOG(info, #{msg => "connection_rejected_due_to_license_limit_reached"}), {stop, {error, ?RC_QUOTA_EXCEEDED}}; false -> {ok, AckProps} diff --git a/changes/ce/fix-12513.en.md b/changes/ce/fix-12513.en.md new file mode 100644 index 000000000..00c1e8537 --- /dev/null +++ b/changes/ce/fix-12513.en.md @@ -0,0 +1 @@ +Change level of several flooding log events from warning to info.