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)