@Override
        public CompletableFuture<ByteBuf> readNodeRangeIndex(long nodeId) {
            ObjectStorage storage = objectReaderFactory.getObjectStorage();
            return storage.read(new ReadOptions().bucket(ObjectAttributes.MATCH_ALL_BUCKET), ObjectUtils.genIndexKey(0, nodeId));
        }
After use, the caller must call {@link Image#close()} to release the image.
core/src/main/scala/kafka/log/stream/s3/metadata/StreamMetadataManager.java