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

- Packages that use KafkaConsumer
  Package | Description
  --- | ---
  io.vertx.kafka.client.consumer |
  io.vertx.reactivex.kafka.client.consumer |
  io.vertx.rxjava3.kafka.client.consumer |

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

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

  - ### Uses of KafkaConsumer in io.vertx.reactivex.kafka.client.consumer

    Methods in io.vertx.reactivex.kafka.client.consumer that return KafkaConsumer
    Modifier and Type | Method | Description
    --- | --- | ---
    `KafkaConsumer` | KafkaConsumer.`getDelegate()` |

    Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumer
    Modifier and Type | Method | Description
    --- | --- | ---
    `static <K,​V> KafkaConsumer<K,​V>` | KafkaConsumer.`newInstance​(KafkaConsumer arg)` |
    `static <K,​V> KafkaConsumer<K,​V>` | KafkaConsumer.`newInstance​(KafkaConsumer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)` |

    Constructors in io.vertx.reactivex.kafka.client.consumer with parameters of type KafkaConsumer
    Constructor | Description
    --- | ---
    `KafkaConsumer​(KafkaConsumer delegate)` |

  - ### Uses of KafkaConsumer in io.vertx.rxjava3.kafka.client.consumer

    Methods in io.vertx.rxjava3.kafka.client.consumer that return KafkaConsumer
    Modifier and Type | Method | Description
    --- | --- | ---
    `KafkaConsumer` | KafkaConsumer.`getDelegate()` |

    Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumer
    Modifier and Type | Method | Description
    --- | --- | ---
    `static <K,​V> KafkaConsumer<K,​V>` | KafkaConsumer.`newInstance​(KafkaConsumer arg)` |
    `static <K,​V> KafkaConsumer<K,​V>` | KafkaConsumer.`newInstance​(KafkaConsumer arg, io.vertx.lang.rx.TypeArg<K> __typeArg_K, io.vertx.lang.rx.TypeArg<V> __typeArg_V)` |

    Constructors in io.vertx.rxjava3.kafka.client.consumer with parameters of type KafkaConsumer
    Constructor | Description
    --- | ---
    `KafkaConsumer​(KafkaConsumer delegate)` |