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.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 Description default Future<Map<TopicPartition,OffsetAndMetadata>>
KafkaAdminClient. listConsumerGroupOffsets(String groupId)
List the consumer group offsets available in the cluster.Future<Map<TopicPartition,OffsetAndMetadata>>
KafkaAdminClient. listConsumerGroupOffsets(String groupId, ListConsumerGroupOffsetsOptions options)
List the consumer group offsets available in the cluster.Method parameters in io.vertx.kafka.admin with type arguments of type OffsetAndMetadata Modifier and Type Method Description Future<Void>
KafkaAdminClient. alterConsumerGroupOffsets(String groupId, Map<TopicPartition,OffsetAndMetadata> offsets)
Alter committed offsets for a set of partitions in a consumer group. -
Uses of OffsetAndMetadata in io.vertx.kafka.client.consumer
Methods in io.vertx.kafka.client.consumer that return OffsetAndMetadata Modifier and Type Method Description OffsetAndMetadata
OffsetAndMetadata. setMetadata(String metadata)
Set additional metadata for the offset committedOffsetAndMetadata
OffsetAndMetadata. setOffset(long offset)
Set the offset to commitMethods in io.vertx.kafka.client.consumer that return types with arguments of type OffsetAndMetadata Modifier and Type Method 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)
Get the last committed offset for the given partition (whether the commit happened by this process or another).Methods in io.vertx.kafka.client.consumer with parameters of type OffsetAndMetadata Modifier and Type Method Description Future<Void>
KafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)
Overrides the fetch offsets that the consumer will use on the next poll.Method parameters in io.vertx.kafka.client.consumer with type arguments of type OffsetAndMetadata Modifier and Type Method 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.Constructors in io.vertx.kafka.client.consumer with parameters of type OffsetAndMetadata Constructor 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 Description Future<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).Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type OffsetAndMetadata Modifier and Type Method Description Completable
KafkaConsumer. rxSeek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)
Overrides the fetch offsets that the consumer will use on the next poll.Future<Void>
KafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)
Overrides the fetch offsets that the consumer will use on the next poll. -
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 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).Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type OffsetAndMetadata Modifier and Type Method Description Completable
KafkaConsumer. rxSeek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)
Overrides the fetch offsets that the consumer will use on the next poll.Completable
KafkaConsumer. seek(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)
Overrides the fetch offsets that the consumer will use on the next poll.
-