public class LagInfo
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
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.
|
long |
endOffsetPosition()
Get the end offset position for this store partition's changelog topic on the Kafka brokers.
|
boolean |
equals(java.lang.Object obj) |
int |
hashCode() |
long |
offsetLag()
Get the measured lag between current and end offset positions, for this store partition replica
|
java.lang.String |
toString() |
public long currentOffsetPosition()
public long endOffsetPosition()
public long offsetLag()
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object