## Uses of Interface
io.vertx.kafka.client.consumer.KafkaReadStream

- Packages that use KafkaReadStream
  Package | Description
  --- | ---
  io.vertx.kafka.client.consumer |

- - ### Uses of KafkaReadStream in io.vertx.kafka.client.consumer

    Methods in io.vertx.kafka.client.consumer that return KafkaReadStream
    Modifier and Type | Method | Description
    --- | --- | ---
    `KafkaReadStream<K,​V>` | KafkaConsumer.`asStream()` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`batchHandler​(Handler<org.apache.kafka.clients.consumer.ConsumerRecords<K,​V>> handler)` | Set the handler that will be called when a new batch of records is returned from Kafka.
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, KafkaClientOptions options)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, KafkaClientOptions options, Class<K> keyType, Class<V> valueType)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, KafkaClientOptions options, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Map<String,​Object> config)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Map<String,​Object> config, Class<K> keyType, Class<V> valueType)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Map<String,​Object> config, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Properties config)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Properties config, Class<K> keyType, Class<V> valueType)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, Properties config, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, org.apache.kafka.common.serialization.Deserializer<V> valueDeserializer)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,​V> consumer)` | Create a new KafkaReadStream instance
    `static <K,​V> KafkaReadStream<K,​V>` | KafkaReadStream.`create​(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,​V> consumer, KafkaClientOptions options)` | Create a new KafkaReadStream instance
    `KafkaReadStream<K,​V>` | KafkaReadStream.`endHandler​(Handler<Void> endHandler)` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`exceptionHandler​(Handler<Throwable> handler)` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`fetch​(long amount)` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`handler​(Handler<org.apache.kafka.clients.consumer.ConsumerRecord<K,​V>> handler)` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`partitionsAssignedHandler​(Handler<Set<org.apache.kafka.common.TopicPartition>> handler)` | Set the handler called when topic partitions are assigned to the consumer
    `KafkaReadStream<K,​V>` | KafkaReadStream.`partitionsRevokedHandler​(Handler<Set<org.apache.kafka.common.TopicPartition>> handler)` | Set the handler called when topic partitions are revoked to the consumer
    `KafkaReadStream<K,​V>` | KafkaReadStream.`pause()` |
    `KafkaReadStream<K,​V>` | KafkaReadStream.`pollTimeout​(Duration timeout)` | Sets the poll timeout for the underlying native Kafka Consumer.
    `KafkaReadStream<K,​V>` | KafkaReadStream.`resume()` |