public long currentOffsetPosition() {
        return this.currentOffsetPosition;
    }
Get the current maximum offset on the store partition's changelog topic, that has been successfully written into
the store partition's state store.

@return current consume offset for standby/restoring store partitions &amp;   simply endoffset for active store partition replicas
streams/src/main/java/org/apache/kafka/streams/LagInfo.java