Method Detail

• currentOffsetPosition

  public long currentOffsetPosition()

  Get the current maximum offset on the store partition's changelog topic, that has been successfully written into the store partition's state store.

  Returns:

  current consume offset for standby/restoring store partitions & simply endoffset for active store partition replicas

• endOffsetPosition

  public long endOffsetPosition()

  Get the end offset position for this store partition's changelog topic on the Kafka brokers.

  Returns:

  last offset written to the changelog topic partition

• offsetLag

  public long offsetLag()

  Get the measured lag between current and end offset positions, for this store partition replica

  Returns:

  lag as measured by message offsets

• equals

  public boolean equals(Object obj)

  Overrides:

  equals in class Object

• hashCode

  public int hashCode()

  Overrides:

  hashCode in class Object

• toString

  public String toString()

  Overrides:

  toString in class Object