docs: public static ByteBuffer getNextChunk(byte[] schemaBytes, ByteBuffer buf,
                                            CachedByteBufferAllocator resultBufferAllocator) {
          buf.position(buf.position() + 4);//skip partition id
          int length = schemaBytes.length + buf.remaining();
  
          ByteBuffer outputBuffer = resultBufferAllocator.allocate(length);
          outputBuffer.put(schemaBytes);
          outputBuffer.put(buf);
          outputBuffer.flip();
  
          return outputBuffer;
      }