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
handler - handler called on operation completed
Return
current KafkaWriteStream instance