vertx / io.vertx.rxjava.kafka.client.consumer

## Package io.vertx.rxjava.kafka.client.consumer

### Types

KafkaConsumer | `open class KafkaConsumer<K : Any, V : Any> : ReadStream<KafkaConsumerRecord<K, V>>` Vert.x Kafka consumer. You receive Kafka records by providing a `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#handler`. As messages arrive the handler will be called with the records. The `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#pause` and `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#resume` provides global control over reading the records from the consumer. The `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#pause` and `io.vertx.rxjava.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.
KafkaConsumerRecords | `open class KafkaConsumerRecords<K : Any, V : Any>` Vert.x Kafka consumer records NOTE: This class has been automatically generated from the io.vertx.kafka.client.consumer.KafkaConsumerRecords non RX-ified interface using Vert.x codegen.