org.apache.kafka.clients.admin

Class DescribeReplicaLogDirsResult.ReplicaLogDirInfo

java.lang.Object

org.apache.kafka.clients.admin.DescribeReplicaLogDirsResult.ReplicaLogDirInfo

Enclosing class:

DescribeReplicaLogDirsResult

public static class DescribeReplicaLogDirsResult.ReplicaLogDirInfo
extends Object

Method Summary

Modifier and Type	Method and Description
String	getCurrentReplicaLogDir() The current log directory of the replica of this partition on the given broker.
long	getCurrentReplicaOffsetLag() Defined as max(HW of partition - LEO of the replica, 0).
String	getFutureReplicaLogDir() The future log directory of the replica of this partition on the given broker.
long	getFutureReplicaOffsetLag() The LEO of the replica - LEO of the future log of this replica in the destination log directory.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getCurrentReplicaLogDir

public String getCurrentReplicaLogDir()

The current log directory of the replica of this partition on the given broker. Null if no replica is not found for this partition on the given broker.

getCurrentReplicaOffsetLag

public long getCurrentReplicaOffsetLag()

Defined as max(HW of partition - LEO of the replica, 0).

getFutureReplicaLogDir

public String getFutureReplicaLogDir()

The future log directory of the replica of this partition on the given broker. Null if the replica of this partition is not being moved to another log directory on the given broker.

getFutureReplicaOffsetLag

public long getFutureReplicaOffsetLag()

The LEO of the replica - LEO of the future log of this replica in the destination log directory. -1 if either there is not replica for this partition or the replica of this partition is not being moved to another log directory on the given broker.

toString

public String toString()

Overrides:

toString in class Object