produceRecordsWithPartitions
fun KafkaRest.produceRecordsWithPartitions(topic: Topic, clusterId: ClusterId, records: List<Record>, fn: (List<PartitionId>) -> Partitioner<Any?, Any?>): Result<Array<ProducedRecord>?, RemoteFailure>
Rewrites the partitions of records using the passed Partitioner, after getting the list of partitions to write to