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

# Class KafkaOffsetTopicMetrics

java.lang.Object
org.apache.storm.kafka.spout.metrics2.KafkaOffsetTopicMetrics

All Implemented Interfaces:
  `com.codahale.metrics.Metric`, `com.codahale.metrics.MetricSet`

public class KafkaOffsetTopicMetrics extends Object implements com.codahale.metrics.MetricSet
Topic level metrics.

topicName/totalEarliestTimeOffset //gives the total beginning offset of all the associated partitions of this spout topicName/totalLatestTimeOffset //gives the total end offset of all the associated partitions of this spout topicName/totalLatestEmittedOffset //gives the total latest emitted offset of all the associated partitions of this spout topicName/totalLatestCompletedOffset //gives the total latest committed offset of all the associated partitions of this spout topicName/spoutLag // total spout lag of all the associated partitions of this spout topicName/totalRecordsInPartitions //total number of records in all the associated partitions of this spout

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `KafkaOffsetTopicMetrics(String topic)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `Map<String,com.codahale.metrics.Metric>`
  `getMetrics()`

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

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

- ## Constructor Details

  - ### KafkaOffsetTopicMetrics

    public KafkaOffsetTopicMetrics(String topic)

- ## Method Details

  - ### getMetrics

    public Map<String,com.codahale.metrics.Metric> getMetrics()
    Specified by:
      `getMetrics` in interface `com.codahale.metrics.MetricSet`