package consumer
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
class
KafkaConsumer
[K, V] extends ReadStream[KafkaConsumerRecord[K, V]]
Vert.x Kafka consumer.
Vert.x Kafka consumer.
You receive Kafka records by providing a io.vertx.scala.kafka.client.consumer.KafkaConsumer#handler. As messages arrive the handler will be called with the records.
The io.vertx.scala.kafka.client.consumer.KafkaConsumer#pause and io.vertx.scala.kafka.client.consumer.KafkaConsumer#resume provides global control over reading the records from the consumer.
The io.vertx.scala.kafka.client.consumer.KafkaConsumer#pause and io.vertx.scala.kafka.client.consumer.KafkaConsumer#resume provides finer grained control over reading records for specific Topic/Partition, these are Kafka's specific operations.
-
class
KafkaConsumerRecord
[K, V] extends AnyRef
Vert.x Kafka consumer record
-
class
OffsetAndMetadata
extends AnyRef
Provide additional metadata when an offset is committed
Value Members
- object KafkaConsumer
- object KafkaConsumerRecord
- object OffsetAndMetadata