suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unit suspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): Unit
Close 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>): RecordMetadata
Asynchronously write a record to a topic |