api/java/src/main/java/com/navercorp/redis/cluster/connection/RedisProtocol.java
private static byte[] processBulkReply(final RedisInputStream is) {
        int len = Integer.parseInt(is.readLine());
        log.trace("[RedisProtocol] Reply bulk-reply. ${}", len);
        if (len == -1) {
            return null;
        }
        byte[] read = new byte[len];
        int offset = 0;
        while (offset < len) {
            offset += is.read(read, offset, (len - offset));
        }
        // read 2 more bytes for the command delimiter
        is.readByte();
        is.readByte();

        return read;
    }
private static byte[] processBulkReply(final RedisInputStream is) {
        int len = Integer.parseInt(is.readLine());
        log.trace("[RedisProtocol] Reply bulk-reply. ${}", len);
        if (len == -1) {
            return null;
        }
        byte[] read = new byte[len];
        int offset = 0;
        while (offset < len) {
            offset += is.read(read, offset, (len - offset));
        }
        // read 2 more bytes for the command delimiter
        is.readByte();
        is.readByte();

        return read;
    }
Process bulk reply.

@param is the is
@return the byte[]