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.