@Override
    public boolean equals(final Object obj) {
        if (!(obj instanceof LagInfo)) {
            return false;
        }
        final LagInfo other = (LagInfo) obj;
        return currentOffsetPosition == other.currentOffsetPosition
            && endOffsetPosition == other.endOffsetPosition
            && this.offsetLag == other.offsetLag;
    }
Get the measured lag between current and end offset positions, for this store partition replica

@return lag as measured by message offsets
streams/src/main/java/org/apache/kafka/streams/LagInfo.java