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)	Manually assign a partition to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.assignAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Manually assign a list of partition to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.assignmentAndForget()	Get the set of partitions currently assigned to this consumer.
KafkaConsumer<K,V>	KafkaConsumer.batchHandler(Consumer<KafkaConsumerRecords<K,V>> handler)	Set the handler to be used when batches of messages are fetched from the Kafka server.
KafkaConsumer<K,V>	KafkaConsumer.beginningOffsetsAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Get the first offset for the given partitions.
KafkaConsumer<K,V>	KafkaConsumer.closeAndForget()	Close the consumer
KafkaConsumer<K,V>	KafkaConsumer.commitAndForget()	Commit current offsets for all the subscribed list of topics and partition.
KafkaConsumer<K,V>	KafkaConsumer.committedAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Get the last committed offset for the given partition (whether the commit happened by this process or another).
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, io.vertx.kafka.client.common.KafkaClientOptions options)	Create a new KafkaConsumer instance
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.create(Vertx vertx, io.vertx.kafka.client.common.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
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, io.vertx.kafka.client.common.KafkaClientOptions options)	Create a new KafkaConsumer instance from a native Consumer.
KafkaConsumer<K,V>	KafkaConsumer.endHandler(Runnable endHandler)
KafkaConsumer<K,V>	KafkaConsumer.endOffsetsAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Get the last offset for the given partition.
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<K,V> delegate)	Creates a new instance of the KafkaConsumer.
static <K, V> KafkaConsumer<K,V>	KafkaConsumer.newInstance(io.vertx.kafka.client.consumer.KafkaConsumer<K,V> delegate, TypeArg<K> typeArg_0, TypeArg<V> typeArg_1)	Creates a new instance of the KafkaConsumer.
KafkaConsumer<K,V>	KafkaConsumer.offsetsForTimesAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition, Long timestamp)	Look up the offset for the given partition by timestamp.
KafkaConsumer<K,V>	KafkaConsumer.partitionsAssignedHandler(Consumer<Set<io.vertx.kafka.client.common.TopicPartition>> handler)	Set the handler called when topic partitions are assigned to the consumer
KafkaConsumer<K,V>	KafkaConsumer.partitionsForAndForget(String topic)	Get metadata about the partitions for a given topic.
KafkaConsumer<K,V>	KafkaConsumer.partitionsRevokedHandler(Consumer<Set<io.vertx.kafka.client.common.TopicPartition>> handler)	Set the handler called when topic partitions are revoked to the consumer
KafkaConsumer<K,V>	KafkaConsumer.pause()
KafkaConsumer<K,V>	KafkaConsumer.pauseAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Suspend fetching from the requested partition.
KafkaConsumer<K,V>	KafkaConsumer.pauseAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Suspend fetching from the requested partitions.
KafkaConsumer<K,V>	KafkaConsumer.pausedAndForget()	Get the set of partitions that were previously paused by a call to pause(Set).
KafkaConsumer<K,V>	KafkaConsumer.pipeToAndForget(WriteStream<KafkaConsumerRecord<K,V>> dst)	Pipe this ReadStream to the WriteStream.
KafkaConsumer<K,V>	KafkaConsumer.pollAndForget(Duration timeout)	Executes a poll for getting messages from Kafka.
KafkaConsumer<K,V>	KafkaConsumer.pollTimeout(Duration timeout)	Sets the poll timeout for the underlying native Kafka Consumer.
KafkaConsumer<K,V>	KafkaConsumer.positionAndForget(io.vertx.kafka.client.common.TopicPartition partition)	Get the offset of the next record that will be fetched (if a record with that offset exists).
KafkaConsumer<K,V>	KafkaConsumer.resume()
KafkaConsumer<K,V>	KafkaConsumer.resumeAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Resume specified partition which have been paused with pause.
KafkaConsumer<K,V>	KafkaConsumer.resumeAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Resume specified partitions which have been paused with pause.
KafkaConsumer<K,V>	KafkaConsumer.seekAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition, long offset)	Overrides the fetch offsets that the consumer will use on the next poll.
KafkaConsumer<K,V>	KafkaConsumer.seekAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition, io.vertx.kafka.client.consumer.OffsetAndMetadata offsetAndMetadata)	Overrides the fetch offsets that the consumer will use on the next poll.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginningAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Seek to the first offset for each of the given partition.
KafkaConsumer<K,V>	KafkaConsumer.seekToBeginningAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Seek to the first offset for each of the given partitions.
KafkaConsumer<K,V>	KafkaConsumer.seekToEndAndForget(io.vertx.kafka.client.common.TopicPartition topicPartition)	Seek to the last offset for each of the given partition.
KafkaConsumer<K,V>	KafkaConsumer.seekToEndAndForget(Set<io.vertx.kafka.client.common.TopicPartition> topicPartitions)	Seek to the last offset for each of the given partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscribeAndForget(String topic)	Subscribe to the given topic to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscribeAndForget(Pattern pattern)	Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscribeAndForget(Set<String> topics)	Subscribe to the given list of topics to get dynamically assigned partitions.
KafkaConsumer<K,V>	KafkaConsumer.subscriptionAndForget()	Get the current subscription.
KafkaConsumer<K,V>	KafkaConsumer.unsubscribeAndForget()	Unsubscribe from topics currently subscribed with subscribe.