public void endOffset(long newEndOffset) {
        long oldEndOffset = endOffset.get();
        if (newEndOffset > oldEndOffset) {
            endOffset.set(newEndOffset);
        }
    }
Return the owner (node id) of current range.
metadata/src/main/java/org/apache/kafka/controller/stream/StreamRuntimeMetadata.java