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
Constructors Constructor Description ReplicaInfo(long size, long offsetLag, boolean isFuture)
-
Method Summary
All Methods Instance Methods Concrete Methods 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()
-
-
-
Method Detail
-
size
public long size()
The total size of the log segments in this replica in bytes.
-
offsetLag
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
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.
-
-