open class KafkaConsumer<K : Any, V : Any> : ReadStream<KafkaConsumerRecord<K, V>>
Vert.x Kafka consumer.
You receive Kafka records by providing a io.vertx.reactivex.kafka.client.consumer.KafkaConsumer#handler. As messages arrive the handler will be called with the records.
The io.vertx.reactivex.kafka.client.consumer.KafkaConsumer#pause and io.vertx.reactivex.kafka.client.consumer.KafkaConsumer#resume provides global control over reading the records from the consumer.
The io.vertx.reactivex.kafka.client.consumer.KafkaConsumer#pause and io.vertx.reactivex.kafka.client.consumer.KafkaConsumer#resume provides finer grained control over reading records for specific Topic/Partition, these are Kafka's specific operations.
NOTE: This class has been automatically generated from the io.vertx.kafka.client.consumer.KafkaConsumer non RX-ified interface using Vert.x codegen.
|