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

Uses of OffsetAndMetadata in io.vertx.kafka.admin

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

Modifier and Type	Method and Description
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

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

Modifier and Type	Method and Description
void	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).