tree a9e78fb0f95dd8e355437fc13b7ba2e35d638a52
parent 6a2e6fc0cb1a3c0b966ffe88f8c477c484493ddf
author WangJialing <65590138+wangjialing218@users.noreply.github.com> 1642494406 +0800
committer GitHub <noreply@github.com> 1642494406 +0800
gpgsig -----BEGIN PGP SIGNATURE-----
 
 wsBcBAABCAAQBQJh5nnGCRBK7hj4Ov3rIwAAO58IAJO60hxvWVJJFqxUvJMZ22yt
 9MBdjO1OCsRYUgYmLB86i+4MWgsnxp0nPl9qPp6Dd1vyFX7h3g8r8vyvvSUJnDuo
 HZro7yDgsvaPBK6qMyKThITkOUiyzTm1L45uRooHUmHr+rEZnd955koj/Vu+53qQ
 W+qVhPFuGTDNZdRtorm08wL9vYBhD0gFQPRL9ZvEw3pyZTcOG/rJZs4tCUFrGQ6X
 l1dFyKgMb/7lPhzcTrsd86j0bVCXUhC3i2yr2HeRJGA8z7oVyPCgJL/68m3NqTpO
 bQPNFPOWyUTP4ng3vhsnWhe+a/vxcmQlHi/Nr3dZpl6LPjGYZqH9pk9/hb77tK8=
 =SRsp
 -----END PGP SIGNATURE-----
 

Support broker level dispatch rate limiter (#11325)

### Motivation

Fixes #7720

Current we support broker level publish rate limiter.
This PR will add broker level dispatch rate limiter.

### Modifications

Add broker level dispatch rate limiter for msgs and bytes.
Refact calculateToRead() to reduce duplicate code.

### Verifying this change

Add testBrokerBytesRateLimitingReceiveAllMessagesAfterThrottling()