vertx-lang-scala-docs_2.12 3.9.1 API < Back
 

# Packages

-  package root
  Definition Classes
    root
-  package io
  Definition Classes
    root
-  package vertx
  Definition Classes
    io
-  package scala
  Definition Classes
    vertx
-  package kafka
  Definition Classes
    scala
-  package client
  Definition Classes
    kafka
-  package common
  Definition Classes
    client
-  package consumer
  Definition Classes
    client
- KafkaConsumer
- KafkaConsumerRecord
- KafkaConsumerRecords
- OffsetAndMetadata
- OffsetAndTimestamp
-  package producer
  Definition Classes
    client

p

io.vertx.scala.kafka.client

# consumer 

#### package consumer

 
Ordering

1. Alphabetic

Visibility

1. Public
2. All

### Type Members

1.  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.

2.  class KafkaConsumerRecord[K, V] extends AnyRef

   Vert.x Kafka consumer record

3.  class KafkaConsumerRecords[K, V] extends AnyRef

   Vert.x Kafka consumer records

4.  class OffsetAndMetadata extends AnyRef

   Provide additional metadata when an offset is committed

5.  class OffsetAndTimestamp extends AnyRef

   Represent information related to a Offset with timestamp information

### Value Members

1.  object KafkaConsumer
2.  object KafkaConsumerRecord
3.  object KafkaConsumerRecords
4.  object OffsetAndMetadata
5.  object OffsetAndTimestamp

### Ungrouped