Uses of Class
io.vertx.kafka.client.consumer.OffsetAndMetadata

Packages that use OffsetAndMetadata

Package	Description
io.vertx.kafka.admin
io.vertx.kafka.client.consumer
io.vertx.reactivex.kafka.client.consumer
io.vertx.rxjava.kafka.client.consumer
io.vertx.rxjava3.kafka.client.consumer

Uses of OffsetAndMetadata in io.vertx.kafka.admin

Methods in io.vertx.kafka.admin that return types with arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
default Future<Map<TopicPartition,OffsetAndMetadata>>	KafkaAdminClient.listConsumerGroupOffsets(String groupId) Like KafkaAdminClient.listConsumerGroupOffsets(String, Handler) but returns a Future of the asynchronous result
Future<Map<TopicPartition,OffsetAndMetadata>>	KafkaAdminClient.listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options) Like KafkaAdminClient.listConsumerGroupOffsets(String, ListConsumerGroupOffsetsOptions, Handler) but returns a Future of the asynchronous result

Method parameters in io.vertx.kafka.admin with type arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Future<Void>	KafkaAdminClient.alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets) Like KafkaAdminClient.alterConsumerGroupOffsets(String, Map, Handler) but returns a Future of the asynchronous result
void	KafkaAdminClient.alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets, Handler<AsyncResult<Void>> completionHandler) Alter committed offsets for a set of partitions in a consumer group.
default void	KafkaAdminClient.listConsumerGroupOffsets(String groupId, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler) List the consumer group offsets available in the cluster.
void	KafkaAdminClient.listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler) List the consumer group offsets available in the cluster.

Uses of OffsetAndMetadata in io.vertx.kafka.client.consumer

Methods in io.vertx.kafka.client.consumer that return OffsetAndMetadata

Modifier and Type	Method and Description
OffsetAndMetadata	OffsetAndMetadata.setMetadata(String metadata) Set additional metadata for the offset committed
OffsetAndMetadata	OffsetAndMetadata.setOffset(long offset) Set the offset to commit

Methods in io.vertx.kafka.client.consumer that return types with arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Future<Map<TopicPartition,OffsetAndMetadata>>	KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets) Commit the specified offsets for the specified list of topics and partitions to Kafka.
Future<OffsetAndMetadata>	KafkaConsumer.committed(TopicPartition topicPartition) Like KafkaConsumer.committed(TopicPartition, Handler) but returns a Future of the asynchronous result

Method parameters in io.vertx.kafka.client.consumer with type arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Future<Map<TopicPartition,OffsetAndMetadata>>	KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets) Commit the specified offsets for the specified list of topics and partitions to Kafka.
void	KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler) Commit the specified offsets for the specified list of topics and partitions to Kafka.
void	KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets, Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler) Commit the specified offsets for the specified list of topics and partitions to Kafka.
void	KafkaConsumer.committed(TopicPartition topicPartition, Handler<AsyncResult<OffsetAndMetadata>> handler) Get the last committed offset for the given partition (whether the commit happened by this process or another).

Constructors in io.vertx.kafka.client.consumer with parameters of type OffsetAndMetadata

Constructor and Description
OffsetAndMetadata(OffsetAndMetadata that) Constructor (copy)

Uses of OffsetAndMetadata in io.vertx.reactivex.kafka.client.consumer

Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Single<OffsetAndMetadata>	KafkaConsumer.rxCommitted(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).

Method parameters in io.vertx.reactivex.kafka.client.consumer with type arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
void	KafkaConsumer.committed(TopicPartition topicPartition, Handler<AsyncResult<OffsetAndMetadata>> handler) Get the last committed offset for the given partition (whether the commit happened by this process or another).

Uses of OffsetAndMetadata in io.vertx.rxjava.kafka.client.consumer

Methods in io.vertx.rxjava.kafka.client.consumer that return types with arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Single<OffsetAndMetadata>	KafkaConsumer.rxCommitted(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).

Method parameters in io.vertx.rxjava.kafka.client.consumer with type arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
void	KafkaConsumer.committed(TopicPartition topicPartition, Handler<AsyncResult<OffsetAndMetadata>> handler) Get the last committed offset for the given partition (whether the commit happened by this process or another).

Uses of OffsetAndMetadata in io.vertx.rxjava3.kafka.client.consumer

Methods in io.vertx.rxjava3.kafka.client.consumer that return types with arguments of type OffsetAndMetadata

Modifier and Type	Method and Description
Single<OffsetAndMetadata>	KafkaConsumer.committed(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).
Single<OffsetAndMetadata>	KafkaConsumer.rxCommitted(TopicPartition topicPartition) Get the last committed offset for the given partition (whether the commit happened by this process or another).