vertx / io.vertx.reactivex.kafka.client.consumer / KafkaConsumer / toObservable

toObservable

open fun toObservable(): Observable<KafkaConsumerRecord<K, V>>

Overrides ReadStream.toObservable