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

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

abortTransactionAwait

suspend fun <K, V> KafkaProducer<K, V>.abortTransactionAwait(): Unit

beginTransactionAwait

suspend fun <K, V> KafkaProducer<K, V>.beginTransactionAwait(): Unit

closeAwait

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

commitTransactionAwait

suspend fun <K, V> KafkaProducer<K, V>.commitTransactionAwait(): Unit

endAwait

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

flushAwait

suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit

Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.flush

initTransactionsAwait

suspend fun <K, V> KafkaProducer<K, V>.initTransactionsAwait(): Unit

partitionsForAwait

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

Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.partitionsFor

sendAwait

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

Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.send

writeAwait

suspend fun <K, V> KafkaProducer<K, V>.writeAwait(data: KafkaProducerRecord<K, V>): Unit

Suspending version of method io.vertx.kafka.client.producer.KafkaProducer.write