Class KafkaOffsetTopicMetrics
java.lang.Object
org.apache.storm.kafka.spout.metrics2.KafkaOffsetTopicMetrics
- All Implemented Interfaces:
- com.codahale.metrics.Metric,- 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 SummaryConstructors
- 
Method Summary
- 
Constructor Details- 
KafkaOffsetTopicMetrics
 
- 
- 
Method Details- 
getMetrics- Specified by:
- getMetricsin interface- com.codahale.metrics.MetricSet
 
 
-