| suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unitsuspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): UnitClose the producer | |
| suspend fun <K, V> KafkaProducer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>Get the partition metadata for the give topic. | |
| suspend fun <K, V> KafkaProducer<K, V>.writeAwait(record: KafkaProducerRecord<K, V>): RecordMetadataAsynchronously write a record to a topic |