diff --git a/src/emqx_protocol.erl b/src/emqx_protocol.erl index 1bbfc2e05..343faedec 100644 --- a/src/emqx_protocol.erl +++ b/src/emqx_protocol.erl @@ -947,7 +947,7 @@ do_flapping_detect(Action, #pstate{zone = Zone, client_id = ClientId, enable_flapping_detect = true}) -> BanExpiryInterval = emqx_zone:get_env(Zone, flapping_ban_expiry_interval, 3600000), - Threshold = emqx_zone:get_env(Zone, flapping_threshold, 20), + Threshold = emqx_zone:get_env(Zone, flapping_threshold, {10, 60}), Until = erlang:system_time(second) + BanExpiryInterval, case emqx_flapping:check(Action, ClientId, Threshold) of flapping ->