docs: private void flushNewPartitions() {
  		LOG.info("Flushing new partitions");
  		TransactionalRequestResult result = enqueueNewPartitions();
  		Object sender = getValue(kafkaProducer, "sender");
  		invoke(sender, "wakeup");
  		result.await();
  	}