Skip to content
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.

Commit ed81beb

Browse files
authoredJun 11, 2025··
Update KafkaOffsetMetricManager.java
1 parent 4d1759e commit ed81beb

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed
 

‎external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetMetricManager.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ public void registerMetricsForNewTopicPartitions(Set<TopicPartition> newAssignme
6464
String topic = topicPartition.topic();
6565
KafkaOffsetTopicMetrics topicMetrics = topicMetricsMap.get(topic);
6666
if (topicMetrics == null) {
67+
LOG.info("Registering metric for topic: {}", topic);
6768
topicMetrics = new KafkaOffsetTopicMetrics(topic, offsetManagerSupplier, adminSupplier, newAssignment);
6869
topicMetricsMap.put(topic, topicMetrics);
6970
topologyContext.registerMetricSet("kafkaOffset", topicMetrics);

0 commit comments

Comments
 (0)
Please sign in to comment.