@Override
    public String toString() {
        return "S3StreamMetadata{" +
            "currentEpoch=" + currentEpoch.get() +
            ", currentState=" + currentState.get() +
            ", currentRangeIndex=" + currentRangeIndex.get() +
            ", startOffset=" + startOffset.get() +
            ", ranges=" + ranges +
            ", streamObjects=" + streamObjects +
            '}';
    }
Return the owner (node id) of current range.
metadata/src/main/java/org/apache/kafka/controller/stream/StreamRuntimeMetadata.java