produceMessagesWithPartitions
fun KafkaRest.produceMessagesWithPartitions(topic: Topic, records: Records, fn: (List<PartitionId>) -> Partitioner<Any?, Any?>): Result<ProducedMessages?, RemoteFailure>
Rewrites the partitions of messages using the passed Partitioner, after getting the list of partitions to write to