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

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.
Uuid	replicaDirectoryId()	Return the directory id of the replica if configured, or Uuid.ZERO_UUID if not.
int	replicaId()	Return the ID for this replica.
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Method Details

replicaId

public int replicaId()

Return the ID for this replica.

Returns:

The ID for this replica

replicaDirectoryId

public Uuid replicaDirectoryId()

Return the directory id of the replica if configured, or Uuid.ZERO_UUID if not.

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

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