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

Packages that use OffsetAndMetadata

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

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).