kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [kafka] branch trunk updated (b351493 -> b5f90da)
Date Thu, 06 Aug 2020 16:13:00 GMT
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


Mime
View raw message