This is an automated email from the ASF dual-hosted git repository.
davidarthur pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d2c06c9 KAFKA-12619; Raft leader should expose hw only after
committing LeaderChange (#10481)
add 5964401 KAFKA-12406 Integrate client quotas with KRaft broker (#10254)
No new revisions were added by this update.
Summary of changes:
.../message/DescribeClientQuotasRequest.json | 2 +-
.../src/main/scala/kafka/server/BrokerServer.scala | 3 +-
core/src/main/scala/kafka/server/KafkaApis.scala | 68 ++++++----
.../main/scala/kafka/server/MetadataSupport.scala | 5 +-
.../kafka/server/metadata/ClientQuotaCache.scala | 12 +-
.../metadata/ClientQuotaMetadataManager.scala | 26 ++--
core/src/test/java/kafka/test/ClusterConfig.java | 4 +-
.../kafka/test/junit/ClusterTestExtensions.java | 8 +-
.../test/junit/RaftClusterInvocationContext.java | 4 +-
.../test/junit/ZkClusterInvocationContext.java | 2 +-
core/src/test/java/kafka/testkit/TestKitNodes.java | 2 +-
.../integration/kafka/server/RaftClusterTest.scala | 111 +++++++++++++++-
.../kafka/server/ClientQuotasRequestTest.scala | 142 +++++++++++----------
.../scala/unit/kafka/server/KafkaApisTest.scala | 6 +-
.../test/scala/unit/kafka/utils/TestUtils.scala | 22 ++++
.../controller/ClientQuotaControlManager.java | 36 ++++--
.../controller/ClientQuotaControlManagerTest.java | 22 +++-
17 files changed, 335 insertions(+), 140 deletions(-)
