root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

MINOR: cleanup in QuotaFactory (#20312) 

cleanup in QuotaFactory.

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Lan Ding 2025-08-07 00:05:45 +08:00 committed by GitHub
parent 4a6a5466fa
commit 71442bf42f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 8 additions and 55 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
core/src/main/java/kafka/server/QuotaFactory.java
View File

@ -51,61 +51,14 @@ public class QuotaFactory {
}
};
public static class QuotaManagers {
private final ClientQuotaManager fetch;
private final ClientQuotaManager produce;
private final ClientRequestQuotaManager request;
private final ControllerMutationQuotaManager controllerMutation;
private final ReplicationQuotaManager leader;
private final ReplicationQuotaManager follower;
private final ReplicationQuotaManager alterLogDirs;
private final Optional<Plugin<ClientQuotaCallback>> clientQuotaCallbackPlugin;
public QuotaManagers(ClientQuotaManager fetch, ClientQuotaManager produce, ClientRequestQuotaManager request,
ControllerMutationQuotaManager controllerMutation, ReplicationQuotaManager leader,
ReplicationQuotaManager follower, ReplicationQuotaManager alterLogDirs,
public record QuotaManagers(ClientQuotaManager fetch,
ClientQuotaManager produce,
ClientRequestQuotaManager request,
ControllerMutationQuotaManager controllerMutation,
ReplicationQuotaManager leader,
ReplicationQuotaManager follower,
ReplicationQuotaManager alterLogDirs,
Optional<Plugin<ClientQuotaCallback>> clientQuotaCallbackPlugin) {
this.fetch = fetch;
this.produce = produce;
this.request = request;
this.controllerMutation = controllerMutation;
this.leader = leader;
this.follower = follower;
this.alterLogDirs = alterLogDirs;
this.clientQuotaCallbackPlugin = clientQuotaCallbackPlugin;
}
public ClientQuotaManager fetch() {
return fetch;
}
public ClientQuotaManager produce() {
return produce;
}
public ClientRequestQuotaManager request() {
return request;
}
public ControllerMutationQuotaManager controllerMutation() {
return controllerMutation;
}
public ReplicationQuotaManager leader() {
return leader;
}
public ReplicationQuotaManager follower() {
return follower;
}
public ReplicationQuotaManager alterLogDirs() {
return alterLogDirs;
}
public Optional<Plugin<ClientQuotaCallback>> clientQuotaCallbackPlugin() {
return clientQuotaCallbackPlugin;
}
public void shutdown() {
fetch.shutdown();