From 23d7c029e3871e1fdcb30ecac60abacf7e2de594 Mon Sep 17 00:00:00 2001
From: Shichao Nie <niesc@automq.com>
Date: Thu, 15 Aug 2024 10:25:41 +0800
Subject: [PATCH] fix(metrics): topic partition count metrics should be
 reported by all brokers (#1802)

Signed-off-by: Shichao Nie <niesc@automq.com>
---
 .../server/metrics/s3stream/S3StreamKafkaMetricsManager.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/server-common/src/main/java/org/apache/kafka/server/metrics/s3stream/S3StreamKafkaMetricsManager.java b/server-common/src/main/java/org/apache/kafka/server/metrics/s3stream/S3StreamKafkaMetricsManager.java
index b1ccd2e375..dd0630c992 100644
--- a/server-common/src/main/java/org/apache/kafka/server/metrics/s3stream/S3StreamKafkaMetricsManager.java
+++ b/server-common/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;