Package org.apache.kafka.clients.admin
Class QuorumInfo.ReplicaState
- java.lang.Object
-
- org.apache.kafka.clients.admin.QuorumInfo.ReplicaState
-
- Enclosing class:
- QuorumInfo
public static class QuorumInfo.ReplicaState extends Object
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
OptionalLong
lastCaughtUpTimestamp()
Return the last millisecond timestamp at which this replica was known to be caught up with the leader.OptionalLong
lastFetchTimestamp()
Return the last millisecond timestamp that the leader received a fetch from this replica.long
logEndOffset()
Return the logEndOffset known by the leader for this replica.int
replicaId()
Return the ID for this replica.String
toString()
-
-
-
Method Detail
-
replicaId
public int replicaId()
Return the ID for this replica.- Returns:
- The ID for this replica
-
logEndOffset
public long logEndOffset()
Return the logEndOffset known by the leader for this replica.- Returns:
- The logEndOffset for this replica
-
lastFetchTimestamp
public OptionalLong lastFetchTimestamp()
Return the last millisecond timestamp that the leader received a fetch from this replica.- Returns:
- The value of the lastFetchTime if known, empty otherwise
-
lastCaughtUpTimestamp
public OptionalLong lastCaughtUpTimestamp()
Return the last millisecond timestamp at which this replica was known to be caught up with the leader.- Returns:
- The value of the lastCaughtUpTime if known, empty otherwise
-
-