code: CompletableFuture<Void> produce(byte[] bytes) {
      return session.producer().append(bytes).thenApply(v -> null);
    }
docs: Produces the given bytes to the partition.
  
  @param bytes the bytes to produce
  @return a future to be completed once the bytes have been written to the partition