Add KAFKA_LEADER_COUNT_METRIC back to watchPartition in LeadershipWat…

…cher
pinterest · Nov 13, 2024 · 6640e51 · 6640e51
1 parent fa14866
commit 6640e51
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/...rc/main/java/com/pinterest/kafka/tieredstorage/uploader/leadership/LeadershipWatcher.java b/...rc/main/java/com/pinterest/kafka/tieredstorage/uploader/leadership/LeadershipWatcher.java
@@ -66,6 +66,14 @@ private void watchPartition(TopicPartition topicPartition) {
                 "cluster=" + environmentProvider.clusterId(),
                 "broker=" + environmentProvider.brokerId()
         );
+        MetricRegistryManager.getInstance(config.getMetricsConfiguration()).updateCounter(
+                topicPartition.topic(),
+                topicPartition.partition(),
+                UploaderMetrics.KAFKA_LEADER_COUNT_METRIC,
+                1,
+                "cluster=" + environmentProvider.clusterId(),
+                "broker=" + environmentProvider.brokerId()
+        );
     }
 
     private void unwatchPartition(TopicPartition topicPartition) {