org.apache.storm.kafka

Class KafkaUtils.KafkaOffsetMetric

java.lang.Object

org.apache.storm.kafka.KafkaUtils.KafkaOffsetMetric

All Implemented Interfaces:

IMetric

Enclosing class:

KafkaUtils

public static class KafkaUtils.KafkaOffsetMetric
extends Object
implements IMetric

Constructor Summary

Constructors

Constructor and Description
KafkaOffsetMetric(DynamicPartitionConnections connections)

Method Summary

Modifier and Type	Method and Description
Object	getValueAndReset()
void	refreshPartitions(Set<Partition> partitions)
void	setOffsetData(Partition partition, PartitionManager.OffsetData offsetData)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaOffsetMetric

public KafkaOffsetMetric(DynamicPartitionConnections connections)

Method Detail

setOffsetData

public void setOffsetData(Partition partition,
                          PartitionManager.OffsetData offsetData)

getValueAndReset

public Object getValueAndReset()

Specified by:

getValueAndReset in interface IMetric

refreshPartitions

public void refreshPartitions(Set<Partition> partitions)