vertx / io.vertx.rxjava.kafka.client.producer / KafkaProducer / write

write

open fun write(kafkaProducerRecord: KafkaProducerRecord<K, V>): KafkaProducer<K, V> open fun write(record: KafkaProducerRecord<K, V>, handler: Handler<AsyncResult<RecordMetadata>>): KafkaProducer<K, V>

Asynchronously write a record to a topic

Parameters

record - record to write

handler - handler called on operation completed

Return
current KafkaWriteStream instance