suspend fun <K, V> KafkaProducer<K, V>.abortTransactionAwait(): Unit |
|
suspend fun <K, V> KafkaProducer<K, V>.beginTransactionAwait(): Unit |
|
suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unit suspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): Unit
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.close |
|
suspend fun <K, V> KafkaProducer<K, V>.commitTransactionAwait(): Unit |
|
suspend fun <K, V> KafkaProducer<K, V>.endAwait(): Unit suspend fun <K, V> KafkaProducer<K, V>.endAwait(data: KafkaProducerRecord<K, V>): Unit
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.end |
|
suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.flush |
|
suspend fun <K, V> KafkaProducer<K, V>.initTransactionsAwait(): Unit |
|
suspend fun <K, V> KafkaProducer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.partitionsFor |
|
suspend fun <K, V> KafkaProducer<K, V>.sendAwait(record: KafkaProducerRecord<K, V>): RecordMetadata
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.send |
|
suspend fun <K, V> KafkaProducer<K, V>.writeAwait(data: KafkaProducerRecord<K, V>): Unit
Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.write |