Package org.apache.storm.kafka.spout.metrics2

# Class KafkaOffsetMetricManager<K,V>

java.lang.Object
org.apache.storm.kafka.spout.metrics2.KafkaOffsetMetricManager<K,V>

public class KafkaOffsetMetricManager<K,V> extends Object
This class is used to manage both the partition and topic level offset metrics.

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, TopologyContext topologyContext)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `Map<String,KafkaOffsetTopicMetrics>`
  `getTopicMetricsMap()`
  `Map<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics>`
  `getTopicPartitionMetricsMap()`
  `void`
  `registerMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Constructor Details

  - ### KafkaOffsetMetricManager

    public KafkaOffsetMetricManager(Supplier<Map<org.apache.kafka.common.TopicPartition,OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, TopologyContext topologyContext)

- ## Method Details

  - ### registerMetricsForNewTopicPartitions

    public void registerMetricsForNewTopicPartitions(Set<org.apache.kafka.common.TopicPartition> newAssignment)

  - ### getTopicPartitionMetricsMap

    public Map<org.apache.kafka.common.TopicPartition,KafkaOffsetPartitionMetrics> getTopicPartitionMetricsMap()

  - ### getTopicMetricsMap

    public Map<String,KafkaOffsetTopicMetrics> getTopicMetricsMap()