org.apache.storm.kafka.monitor

Class KafkaPartitionOffsetLag

java.lang.Object

org.apache.storm.kafka.monitor.KafkaPartitionOffsetLag

public class KafkaPartitionOffsetLag
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaPartitionOffsetLag(long consumerCommittedOffset, long logHeadOffset)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
long	getConsumerCommittedOffset()
long	getLag()
long	getLogHeadOffset()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

KafkaPartitionOffsetLag

public KafkaPartitionOffsetLag(long consumerCommittedOffset,
                               long logHeadOffset)

Method Detail

getConsumerCommittedOffset

public long getConsumerCommittedOffset()

getLogHeadOffset

public long getLogHeadOffset()

getLag

public long getLag()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object