This is an automated email from the ASF dual-hosted git repository.
junrao pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from b351493 KAFKA-9274: Remove `retries` for global task (#9047)
add b5f90da KAFKA-10162; Use Token Bucket algorithm for controller
mutation quota (KIP-599, Part III) (#9114)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/metrics/Sensor.java | 38 ++++++--
.../common/metrics/internals/MetricsUtils.java | 46 ++++++++++
.../apache/kafka/common/metrics/stats/Rate.java | 24 +----
.../kafka/common/metrics/stats/TokenBucket.java | 101 +++++++++++++++++++++
.../apache/kafka/common/metrics/SensorTest.java | 94 +++++++++++++++++++
.../kafka/common/metrics/TokenBucketTest.java | 93 +++++++++++++++++++
.../scala/kafka/server/ClientQuotaManager.scala | 22 +++--
.../server/ControllerMutationQuotaManager.scala | 40 +++++++-
.../kafka/server/ReplicationQuotaManager.scala | 4 +-
.../src/main/scala/kafka/server/SensorAccess.scala | 10 +-
.../ControllerMutationQuotaManagerTest.scala | 58 ++++++++----
.../kafka/server/ControllerMutationQuotaTest.scala | 16 ++--
12 files changed, 467 insertions(+), 79 deletions(-)
create mode 100644
clients/src/main/java/org/apache/kafka/common/metrics/internals/MetricsUtils.java
create mode 100644
clients/src/main/java/org/apache/kafka/common/metrics/stats/TokenBucket.java
create mode 100644
clients/src/test/java/org/apache/kafka/common/metrics/TokenBucketTest.java
