public long getCurrentReplicaOffsetLag() {
            return currentReplicaOffsetLag;
        }
Defined as max(HW of partition - LEO of the replica, 0).
clients/src/main/java/org/apache/kafka/clients/admin/DescribeReplicaLogDirsResult.java