Package 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
  Description
  `KafkaPartitionOffsetLag(long consumerCommittedOffset, long logHeadOffset)`

- ## Method Summary

  Modifier and Type
  Method
  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 Details

  - ### KafkaPartitionOffsetLag

    public KafkaPartitionOffsetLag(long consumerCommittedOffset, long logHeadOffset)

- ## Method Details

  - ### 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`