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 Summary
-
Method Summary
-
Constructor Details
-
KafkaOffsetTopicMetrics
-
-
Method Details
-
getMetrics
- Specified by:
getMetrics
in interfacecom.codahale.metrics.MetricSet
-