Class KafkaOffsetMetricManager<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.metrics2.KafkaOffsetMetricManager<K,V> 
This class is used to manage both the partition and topic level offset metrics.
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, TopologyContext topologyContext) 
- 
Method SummaryModifier and TypeMethodDescriptionMap<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics> voidregisterMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment) 
- 
Constructor Details- 
KafkaOffsetMetricManagerpublic KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, TopologyContext topologyContext) 
 
- 
- 
Method Details- 
registerMetricsForNewTopicPartitionspublic void registerMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment) 
- 
getTopicPartitionMetricsMappublic Map<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics> getTopicPartitionMetricsMap()
- 
getTopicMetricsMap
 
-