vertx / io.vertx.kafka.client.consumer

Package io.vertx.kafka.client.consumer

Types

KafkaConsumer

interface KafkaConsumer<K : Any, V : Any> : ReadStream<KafkaConsumerRecord<K, V>>

Vert.x Kafka consumer.

You receive Kafka records by providing a KafkaConsumer#handler(Handler). As messages arrive the handler will be called with the records.

The #pause() and #resume() provides global control over reading the records from the consumer.

The #pause(Set) and #resume(Set) provides finer grained control over reading records for specific Topic/Partition, these are Kafka's specific operations.

KafkaConsumerRecords

interface KafkaConsumerRecords<K : Any, V : Any>

Vert.x Kafka consumer records

KafkaReadStream

interface KafkaReadStream<K : Any, V : Any> : ReadStream<ConsumerRecord<K, V>>

A ReadStream for consuming Kafka ConsumerRecord.

The #pause() and #resume() provides global control over reading the records from the consumer.

The #pause(Set) and #resume(Set) provides finer grained control over reading records for specific Topic/Partition, these are Kafka's specific operations.