Package org.apache.storm.kafka.spout.metrics2

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 Summary

Constructors

Constructor	Description
KafkaOffsetTopicMetrics(String topic)

Method Summary

Modifier and Type	Method	Description
Map<String,com.codahale.metrics.Metric>	getMetrics()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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