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 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