diff --git a/src/emqx_connection.erl b/src/emqx_connection.erl index a3d3e41a6..a516b8757 100644 --- a/src/emqx_connection.erl +++ b/src/emqx_connection.erl @@ -617,7 +617,7 @@ ensure_rate_limit(Stats, State = #state{limiter = Limiter}) -> {ok, Limiter1} -> State#state{limiter = Limiter1}; {pause, Time, Limiter1} -> - ?LOG(debug, "Pause ~pms due to rate limit", [Time]), + ?LOG(warning, "Pause ~pms due to rate limit", [Time]), TRef = start_timer(Time, limit_timeout), State#state{sockstate = blocked, limiter = Limiter1, diff --git a/src/emqx_ws_connection.erl b/src/emqx_ws_connection.erl index 204dc82ee..97fb5e623 100644 --- a/src/emqx_ws_connection.erl +++ b/src/emqx_ws_connection.erl @@ -414,7 +414,7 @@ ensure_rate_limit(Stats, State = #state{limiter = Limiter}) -> {ok, Limiter1} -> State#state{limiter = Limiter1}; {pause, Time, Limiter1} -> - ?LOG(debug, "Pause ~pms due to rate limit", [Time]), + ?LOG(warning, "Pause ~pms due to rate limit", [Time]), TRef = start_timer(Time, limit_timeout), NState = State#state{sockstate = blocked, limiter = Limiter1,