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 booleanequals(Object o)inthashCode()OptionalLonglastCaughtUpTimestamp()Return the last millisecond timestamp at which this replica was known to be caught up with the leader.OptionalLonglastFetchTimestamp()Return the last millisecond timestamp that the leader received a fetch from this replica.longlogEndOffset()Return the logEndOffset known by the leader for this replica.intreplicaId()Return the ID for this replica.StringtoString()
-
-
-
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
-
-