Package org.apache.kafka.clients.admin

Class ReplicaInfo

java.lang.Object
org.apache.kafka.clients.admin.ReplicaInfo
public class ReplicaInfo extends Object
A description of a replica on a particular broker.

  • Constructor Summary Link icon

    Constructors
    Constructor
    Description
    ReplicaInfo(long size, long offsetLag, boolean isFuture)
     

  • Method Summary Link icon

    Modifier and Type
    Method
    Description
    boolean
    isFuture()
    Whether this replica has been created by a AlterReplicaLogDirsRequest but not yet replaced the current replica on the broker.
    long
    offsetLag()
    The lag of the log's LEO with respect to the partition's high watermark (if it is the current log for the partition) or the current replica's LEO (if it is the future log for the partition).
    long
    size()
    The total size of the log segments in this replica in bytes.
    String
    toString()
     

    Methods inherited from class java.lang.Object Link icon

    equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Constructor Details Link icon

    • ReplicaInfo Link icon

      public ReplicaInfo(long size, long offsetLag, boolean isFuture)

  • Method Details Link icon

    • size Link icon

      public long size()
      The total size of the log segments in this replica in bytes.

    • offsetLag Link icon

      public long offsetLag()
      The lag of the log's LEO with respect to the partition's high watermark (if it is the current log for the partition) or the current replica's LEO (if it is the future log for the partition).

    • isFuture Link icon

      public boolean isFuture()
      Whether this replica has been created by a AlterReplicaLogDirsRequest but not yet replaced the current replica on the broker.
      Returns:
      true if this log is created by AlterReplicaLogDirsRequest and will replace the current log of the replica at some time in the future.

    • toString Link icon

      public String toString()
      Overrides:
      toString in class Object