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 Summary
ConstructorDescriptionKafkaOffsetPartitionMetrics
(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K, V>> consumerSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics) -
Method Summary
-
Constructor Details
-
KafkaOffsetPartitionMetrics
public KafkaOffsetPartitionMetrics(Supplier<Map<org.apache.kafka.common.TopicPartition, OffsetManager>> offsetManagerSupplier, Supplier<org.apache.kafka.clients.consumer.Consumer<K, V>> consumerSupplier, org.apache.kafka.common.TopicPartition topicPartition, KafkaOffsetTopicMetrics topicMetrics)
-
-
Method Details
-
getMetrics
- Specified by:
getMetrics
in interfacecom.codahale.metrics.MetricSet
-