Skip to content

Commit 8491630

Browse files
committed
KAFKA-19817 Move DynamicTopicClusterQuotaPublisher to metadata module
1 parent ec87e38 commit 8491630

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

metadata/src/main/java/org/apache/kafka/metadata/publisher/DynamicTopicClusterQuotaPublisher.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,10 @@ public String name() {
5252

5353
@Override
5454
public void onMetadataUpdate(MetadataDelta delta, MetadataImage newImage, LoaderManifest manifest) {
55+
onMetadataUpdate(delta, newImage);
56+
}
57+
58+
public void onMetadataUpdate(MetadataDelta delta, MetadataImage newImage) {
5559
try {
5660
quotaManagersProvider.clientQuotaCallbackPlugin().ifPresent(plugin -> {
5761
if (delta.topicsDelta() != null || delta.clusterDelta() != null) {

0 commit comments

Comments
 (0)