fix(metrics): topic partition count metrics should be reported by all…

… brokers Signed-off-by: Shichao Nie <[email protected]>
AutoMQ · Aug 14, 2024 · 7819b43 · 7819b43
1 parent 9e1fecf
commit 7819b43
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/src/main/java/org/apache/kafka/server/metrics/s3stream/S3StreamKafkaMetricsManager.java b/...n/src/main/java/org/apache/kafka/server/metrics/s3stream/S3StreamKafkaMetricsManager.java
@@ -118,7 +118,7 @@ private static void initAutoBalancerMetrics(Meter meter, String prefix) {
                 .setDescription("The number of partitions for each topic on each broker")
                 .ofLongs()
                 .buildWithCallback(result -> {
-                    if (MetricsLevel.INFO.isWithin(metricsConfig.getMetricsLevel()) && isActiveSupplier.get()) {
+                    if (MetricsLevel.INFO.isWithin(metricsConfig.getMetricsLevel())) {
                         PartitionCountDistribution partitionCountDistribution = topicPartitionCountSupplier.get();
                         if (partitionCountDistribution == null) {
                             return;