docs: public int createPartitions(String topic, int partitionNum, boolean enlarge) throws IOException {
          KV<Receive, ErrorMapping> response = send(new CreaterRequest(topic, partitionNum, enlarge));
          return Utils.deserializeIntArray(response.k.buffer())[0];
      }