vertx / io.vertx.kotlin.kafka.client.producer / io.vertx.kafka.client.producer.KafkaProducer

Extensions for io.vertx.kafka.client.producer.KafkaProducer

closeAwait

suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): Unit

Close the producer

partitionsForAwait

suspend fun <K, V> KafkaProducer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>

Get the partition metadata for the give topic.

writeAwait

suspend fun <K, V> KafkaProducer<K, V>.writeAwait(record: KafkaProducerRecord<K, V>): RecordMetadata

Asynchronously write a record to a topic