Class KafkaOffsetPartitionMetrics<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.metrics2.KafkaOffsetPartitionMetrics<K,V> 
- All Implemented Interfaces:
- com.codahale.metrics.Metric,- com.codahale.metrics.MetricSet
public class KafkaOffsetPartitionMetrics<K,V> 
extends Object
implements com.codahale.metrics.MetricSet
Partition level metrics.
 
topicName/partition_{number}/earliestTimeOffset //gives beginning offset of the partition topicName/partition_{number}/latestTimeOffset //gives end offset of the partition topicName/partition_{number}/latestEmittedOffset //gives latest emitted offset of the partition from the spout topicName/partition_{number}/latestCompletedOffset //gives latest committed offset of the partition from the spout topicName/partition_{number}/spoutLag // the delta between the latest Offset and latestCompletedOffset topicName/partition_{number}/recordsInPartition // total number of records in the partition
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaOffsetPartitionMetrics(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics) 
- 
Method Summary
- 
Constructor Details- 
KafkaOffsetPartitionMetricspublic KafkaOffsetPartitionMetrics(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.admin.Admin> adminSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics) 
 
- 
- 
Method Details- 
getMetrics- Specified by:
- getMetricsin interface- com.codahale.metrics.MetricSet
 
 
-