Currently the Kafka write overloaded method provides as async result the record metadata write(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>).
Vert.x WriteStream defines so far the write(KakfaProducerRecord<K,V>) method which gets overloaded with write(KafkaProducerRecord<K, V>, Handler<AsyncResult<Void>>) in 3.7.1 as part of an improvement for write streams.
We need to rename the current write(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>) to send(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>) and change the async result type of write to be void.
Currently the Kafka write overloaded method provides as async result the record metadata
write(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>)
.Vert.x
WriteStream
defines so far thewrite(KakfaProducerRecord<K,V>)
method which gets overloaded withwrite(KafkaProducerRecord<K, V>, Handler<AsyncResult<Void>>)
in 3.7.1 as part of an improvement for write streams.We need to rename the current
write(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>)
tosend(KafkaProducerRecord<K, V>, Handler<AsyncResult<RecordMetaData>>)
and change the async result type ofwrite
to be void.