CNKAF-765; Update the TenantQuotaCallback to support Controller Mutation Quota (#2289)
显示
- ce-broker-plugins/src/main/java/io/confluent/kafka/multitenant/quota/TenantQuotaCallback.java 139 个添加, 40 个删除...onfluent/kafka/multitenant/quota/TenantQuotaCallback.java
- ce-broker-plugins/src/test/java/io/confluent/kafka/multitenant/quota/TenantQuotaCallbackTest.java 108 个添加, 60 个删除...uent/kafka/multitenant/quota/TenantQuotaCallbackTest.java
- clients/src/main/java/org/apache/kafka/common/config/internals/ConfluentConfigs.java 7 个添加, 0 个删除...pache/kafka/common/config/internals/ConfluentConfigs.java
- clients/src/test/java/org/apache/kafka/common/metrics/TokenBucketTest.java 31 个添加, 0 个删除...java/org/apache/kafka/common/metrics/TokenBucketTest.java
- core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala 4 个添加, 5 个删除...n/scala/kafka/server/ControllerMutationQuotaManager.scala
- core/src/test/scala/unit/kafka/server/ControllerMutationQuotaManagerTest.scala 2 个添加, 8 个删除...nit/kafka/server/ControllerMutationQuotaManagerTest.scala
- core/src/test/scala/unit/kafka/server/ControllerMutationQuotaTest.scala 1 个添加, 8 个删除...scala/unit/kafka/server/ControllerMutationQuotaTest.scala
加载中
想要评论请 注册 或 登录