Uses of Class
io.vertx.mutiny.kafka.client.consumer.KafkaConsumer

Packages that use KafkaConsumer

Package	Description
io.vertx.mutiny.kafka.client.consumer

Uses of KafkaConsumer in io.vertx.mutiny.kafka.client.consumer

Fields in io.vertx.mutiny.kafka.client.consumer with type parameters of type KafkaConsumer

Modifier and Type	Field	Description
static final TypeArg<KafkaConsumer>	KafkaConsumer.__TYPE_ARG

Methods in io.vertx.mutiny.kafka.client.consumer that return KafkaConsumer

Modifier and Type	Method	Description
KafkaConsumer<K,V>	KafkaConsumer.assignAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Variant of assign(TopicPartition) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.assignAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Variant of assign(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.assignmentAndForget()	Variant of assignment() that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.batchHandler(Consumer<KafkaConsumerRecords<K,V>> handler)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, io.vertx.kafka.client.common.KafkaClientOptions options)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, io.vertx.kafka.client.common.KafkaClientOptions options, Class<K> keyType, Class<V> valueType)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Map<String,String> config)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, Map<String,String> config, Class<K> keyType, Class<V> valueType)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,V> consumer)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, org.apache.kafka.clients.consumer.Consumer<K,V> consumer, io.vertx.kafka.client.common.KafkaClientOptions options)
KafkaConsumer<K,V>	KafkaConsumer.endHandler(Runnable endHandler)
KafkaConsumer<K,V>	KafkaConsumer.exceptionHandler(Consumer<Throwable> handler)
KafkaConsumer<K,V>	KafkaConsumer.fetch(long amount)
KafkaConsumer<K,V>	KafkaConsumer.handler(Consumer<KafkaConsumerRecord<K,V>> handler)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(io.vertx.kafka.client.consumer.KafkaConsumer arg)
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(io.vertx.kafka.client.consumer.KafkaConsumer arg, TypeArg<K> __typeArg_K, TypeArg<V> __typeArg_V)
KafkaConsumer<K,V>	KafkaConsumer.partitionsAssignedHandler(Consumer<Set<io.vertx.kafka.client.common.TopicPartition>> handler)
KafkaConsumer<K,V>	KafkaConsumer.partitionsForAndForget(String topic)	Variant of partitionsFor(String) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.partitionsRevokedHandler(Consumer<Set<io.vertx.kafka.client.common.TopicPartition>> handler)
KafkaConsumer<K,V>	KafkaConsumer.pause()
KafkaConsumer<K,V>	KafkaConsumer.pauseAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Variant of pause(TopicPartition) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.pauseAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Variant of pause(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.pollTimeout(Duration timeout)
KafkaConsumer<K,V>	KafkaConsumer.resume()
KafkaConsumer<K,V>	KafkaConsumer.resumeAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Variant of resume(TopicPartition) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.resumeAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Variant of resume(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.seekAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition, long offset)	Variant of seek(TopicPartition,long) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginningAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Variant of seekToBeginning(TopicPartition) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginningAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Variant of seekToBeginning(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.seekToEndAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Variant of seekToEnd(TopicPartition) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.seekToEndAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Variant of seekToEnd(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.subscribeAndForget(String topic)	Variant of subscribe(String) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.subscribeAndForget(Set<String> topics)	Variant of subscribe(Set) that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.subscriptionAndForget()	Variant of subscription() that ignores the result of the operation.
KafkaConsumer<K,V>	KafkaConsumer.unsubscribeAndForget()	Variant of unsubscribe() that ignores the result of the operation.