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.ReplicaStateextends Object

  • Constructor Details

    • ReplicaState

      public ReplicaState(int replicaId, Uuid replicaDirectoryId, long logEndOffset, OptionalLong lastFetchTimestamp, OptionalLong lastCaughtUpTimestamp)

  • 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