## Uses of Class
io.vertx.rxjava3.kafka.client.consumer.KafkaConsumer

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

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

    Fields in io.vertx.rxjava3.kafka.client.consumer with type parameters of type KafkaConsumer
    Modifier and Type | Field and Description
    --- | ---
    `static io.vertx.lang.rx.TypeArg<KafkaConsumer>` | KafkaConsumer.`__TYPE_ARG`

    Methods in io.vertx.rxjava3.kafka.client.consumer that return KafkaConsumer
    Modifier and Type | Method and 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, 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
    `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)`
    `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)`
    `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()`

Copyright © 2022 Eclipse. All rights reserved.