package consumer
- Alphabetic
- 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
KafkaConsumerRecords[K, V] extends AnyRef
Vert.x Kafka consumer records
-
class
OffsetAndMetadata extends AnyRef
Provide additional metadata when an offset is committed
-
class
OffsetAndTimestamp extends AnyRef
Represent information related to a Offset with timestamp information
Value Members
- object KafkaConsumer
- object KafkaConsumerRecord
- object KafkaConsumerRecords
- object OffsetAndMetadata
- object OffsetAndTimestamp