## Uses of Class
io.vertx.kafka.client.common.TopicPartition

- Packages that use TopicPartition
  Package | Description
  --- | ---
  io.vertx.kafka.admin |
  io.vertx.kafka.client.common |
  io.vertx.kafka.client.consumer |
  io.vertx.reactivex.kafka.admin |
  io.vertx.reactivex.kafka.client.consumer |
  io.vertx.rxjava.kafka.admin |
  io.vertx.rxjava.kafka.client.consumer |
  io.vertx.rxjava3.kafka.admin |
  io.vertx.rxjava3.kafka.client.consumer |

- - ### Uses of TopicPartition in io.vertx.kafka.admin

    Methods in io.vertx.kafka.admin that return types with arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Future<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>` | KafkaAdminClient.`deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)` Like `KafkaAdminClient.deleteRecords(Map, Handler)` but returns a `Future` of the asynchronous result
    `Set<TopicPartition>` | MemberAssignment.`getTopicPartitions()`
    `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
    `Future<Map<TopicPartition,ListOffsetsResultInfo>>` | KafkaAdminClient.`listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)` Like `#listOffsets(Map, Handler)` but returns a `Future` of the asynchronous result
    `List<TopicPartition>` | ListConsumerGroupOffsetsOptions.`topicPartitions()` Returns a list of topic partitions to add as part of the result.

    Method parameters in io.vertx.kafka.admin with type arguments of type TopicPartition
    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.
    `Future<Void>` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Like `KafkaAdminClient.deleteConsumerGroupOffsets(String, Set, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)` Delete committed offsets for a set of partitions in a consumer group.
    `Future<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>` | KafkaAdminClient.`deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)` Like `KafkaAdminClient.deleteRecords(Map, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaAdminClient.`deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete, Handler<AsyncResult<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>> completionHandler)` Delete records from a topic partition.
    `void` | KafkaAdminClient.`deleteRecords(Map<TopicPartition,org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete, Handler<AsyncResult<Map<TopicPartition,org.apache.kafka.clients.admin.DeletedRecords>>> completionHandler)` Delete records from a topic partition.
    `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.
    `Future<Map<TopicPartition,ListOffsetsResultInfo>>` | KafkaAdminClient.`listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets)` Like `#listOffsets(Map, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaAdminClient.`listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets, Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)` List the offsets available for a set of partitions.
    `void` | KafkaAdminClient.`listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets, Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)` List the offsets available for a set of partitions.
    `MemberAssignment` | MemberAssignment.`setTopicPartitions(Set<TopicPartition> topicPartitions)` Set the list of topic partitions
    `ListConsumerGroupOffsetsOptions` | ListConsumerGroupOffsetsOptions.`topicPartitions(List<TopicPartition> topicPartitions)` Set the topic partitions to list as part of the result.

    Constructor parameters in io.vertx.kafka.admin with type arguments of type TopicPartition
    Constructor and Description
    `MemberAssignment(Set<TopicPartition> topicPartitions)` Constructor

  - ### Uses of TopicPartition in io.vertx.kafka.client.common

    Methods in io.vertx.kafka.client.common that return TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `TopicPartition` | TopicPartition.`setPartition(int partition)` Set the partition number
    `TopicPartition` | TopicPartition.`setTopic(String topic)` Set the topic name

    Constructors in io.vertx.kafka.client.common with parameters of type TopicPartition
    Constructor and Description
    `TopicPartition(TopicPartition that)` Constructor (copy)

  - ### Uses of TopicPartition in io.vertx.kafka.client.consumer

    Methods in io.vertx.kafka.client.consumer that return types with arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Future<Set<TopicPartition>>` | KafkaConsumer.`assignment()` Like `KafkaConsumer.assignment(Handler)` but returns a `Future` of the asynchronous result
    `Future<Map<TopicPartition,Long>>` | KafkaConsumer.`beginningOffsets(Set<TopicPartition> topicPartitions)` Like `KafkaConsumer.beginningOffsets(Set, Handler)` but returns a `Future` of the asynchronous result
    `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<Map<TopicPartition,Long>>` | KafkaConsumer.`endOffsets(Set<TopicPartition> topicPartitions)` Like `KafkaConsumer.endOffsets(Set, Handler)` but returns a `Future` of the asynchronous result
    `Future<Map<TopicPartition,OffsetAndTimestamp>>` | KafkaConsumer.`offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)` Like `KafkaConsumer.offsetsForTimes(Map, Handler)` but returns a `Future` of the asynchronous result
    `Future<Set<TopicPartition>>` | KafkaConsumer.`paused()` Like `KafkaConsumer.paused(Handler)` but returns a `Future` of the asynchronous result

    Methods in io.vertx.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Future<Void>` | KafkaConsumer.`assign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Manually assign a partition to this consumer.
    `Future<Long>` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition)` Like `KafkaConsumer.beginningOffsets(TopicPartition, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `Future<OffsetAndMetadata>` | KafkaConsumer.`committed(TopicPartition topicPartition)` Like `KafkaConsumer.committed(TopicPartition, Handler)` but returns a `Future` of the asynchronous result
    `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).
    `Future<Long>` | KafkaConsumer.`endOffsets(TopicPartition topicPartition)` Like `KafkaConsumer.endOffsets(TopicPartition, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`endOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `Future<OffsetAndTimestamp>` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp)` Like `KafkaConsumer.offsetsForTimes(TopicPartition, Long, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp, Handler<AsyncResult<OffsetAndTimestamp>> handler)` Look up the offset for the given partition by timestamp.
    `Future<Void>` | KafkaConsumer.`pause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partition.
    `Future<Long>` | KafkaConsumer.`position(TopicPartition partition)` Like `KafkaConsumer.position(TopicPartition, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`position(TopicPartition partition, Handler<AsyncResult<Long>> handler)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `Future<Void>` | KafkaConsumer.`resume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Resume specified partition which have been paused with pause.
    `Future<Void>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset, Handler<AsyncResult<Void>> completionHandler)` Overrides the fetch offsets that the consumer will use on the next poll.
    `Future<Void>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partition.
    `Future<Void>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partition.

    Method parameters in io.vertx.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Future<Void>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assignment(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions currently assigned to this consumer.
    `Future<Map<TopicPartition,Long>>` | KafkaConsumer.`beginningOffsets(Set<TopicPartition> topicPartitions)` Like `KafkaConsumer.beginningOffsets(Set, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`beginningOffsets(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Map<TopicPartition,Long>>> handler)` Get the first offset for the given partitions.
    `void` | KafkaConsumer.`beginningOffsets(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Map<TopicPartition,Long>>> handler)` Get the first offset for the given partitions.
    `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.
    `Future<Map<TopicPartition,Long>>` | KafkaConsumer.`endOffsets(Set<TopicPartition> topicPartitions)` Like `KafkaConsumer.endOffsets(Set, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`endOffsets(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Map<TopicPartition,Long>>> handler)` Get the last offset for the given partitions.
    `void` | KafkaConsumer.`endOffsets(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Map<TopicPartition,Long>>> handler)` Get the last offset for the given partitions.
    `Future<Map<TopicPartition,OffsetAndTimestamp>>` | KafkaConsumer.`offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)` Like `KafkaConsumer.offsetsForTimes(Map, Handler)` but returns a `Future` of the asynchronous result
    `void` | KafkaConsumer.`offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps, Handler<AsyncResult<Map<TopicPartition,OffsetAndTimestamp>>> handler)` Look up the offsets for the given partitions by timestamp.
    `void` | KafkaConsumer.`offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps, Handler<AsyncResult<Map<TopicPartition,OffsetAndTimestamp>>> handler)` Look up the offsets for the given partitions by timestamp.
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are assigned to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are revoked to the consumer
    `Future<Void>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partitions.
    `void` | KafkaConsumer.`paused(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions that were previously paused by a call to pause(Set).
    `Future<Void>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Resume specified partitions which have been paused with pause.
    `Future<Void>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partitions.
    `Future<Void>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partitions.

  - ### Uses of TopicPartition in io.vertx.reactivex.kafka.admin

    Method parameters in io.vertx.reactivex.kafka.admin with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `void` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.
    `void` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)` Delete committed offsets for a set of partitions in a consumer group.
    `Completable` | KafkaAdminClient.`rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.

  - ### Uses of TopicPartition in io.vertx.reactivex.kafka.client.consumer

    Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxAssignment()` Get the set of partitions currently assigned to this consumer.
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxPaused()` Get the set of partitions that were previously paused by a call to pause(Set).

    Methods in io.vertx.reactivex.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Manually assign a partition to this consumer.
    `void` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `void` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `void` | KafkaConsumer.`committed(TopicPartition topicPartition)` Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `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).
    `void` | KafkaConsumer.`endOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `void` | KafkaConsumer.`endOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `void` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `void` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp, Handler<AsyncResult<OffsetAndTimestamp>> handler)` Look up the offset for the given partition by timestamp.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partition.
    `void` | KafkaConsumer.`position(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `void` | KafkaConsumer.`position(TopicPartition partition, Handler<AsyncResult<Long>> handler)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Resume specified partition which have been paused with pause.
    `Completable` | KafkaConsumer.`rxAssign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `Single<Long>` | KafkaConsumer.`rxBeginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `Single<OffsetAndMetadata>` | KafkaConsumer.`rxCommitted(TopicPartition topicPartition)` Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Single<Long>` | KafkaConsumer.`rxEndOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `Single<OffsetAndTimestamp>` | KafkaConsumer.`rxOffsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `Completable` | KafkaConsumer.`rxPause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `Single<Long>` | KafkaConsumer.`rxPosition(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `Completable` | KafkaConsumer.`rxResume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `Completable` | KafkaConsumer.`rxSeek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `Completable` | KafkaConsumer.`rxSeekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `Completable` | KafkaConsumer.`rxSeekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset, Handler<AsyncResult<Void>> completionHandler)` Overrides the fetch offsets that the consumer will use on the next poll.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partition.

    Method parameters in io.vertx.reactivex.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assignment(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions currently assigned to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are assigned to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are revoked to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partitions.
    `void` | KafkaConsumer.`paused(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions that were previously paused by a call to pause(Set).
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Resume specified partitions which have been paused with pause.
    `Completable` | KafkaConsumer.`rxAssign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `Completable` | KafkaConsumer.`rxPause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `Completable` | KafkaConsumer.`rxResume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `Completable` | KafkaConsumer.`rxSeekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `Completable` | KafkaConsumer.`rxSeekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partitions.

  - ### Uses of TopicPartition in io.vertx.rxjava.kafka.admin

    Method parameters in io.vertx.rxjava.kafka.admin with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `void` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.
    `void` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler)` Delete committed offsets for a set of partitions in a consumer group.
    `Single<Void>` | KafkaAdminClient.`rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.

  - ### Uses of TopicPartition in io.vertx.rxjava.kafka.client.consumer

    Methods in io.vertx.rxjava.kafka.client.consumer that return types with arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxAssignment()` Get the set of partitions currently assigned to this consumer.
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxPaused()` Get the set of partitions that were previously paused by a call to pause(Set).

    Methods in io.vertx.rxjava.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Manually assign a partition to this consumer.
    `void` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `void` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `void` | KafkaConsumer.`committed(TopicPartition topicPartition)` Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `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).
    `void` | KafkaConsumer.`endOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `void` | KafkaConsumer.`endOffsets(TopicPartition topicPartition, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `void` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `void` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp, Handler<AsyncResult<OffsetAndTimestamp>> handler)` Look up the offset for the given partition by timestamp.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partition.
    `void` | KafkaConsumer.`position(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `void` | KafkaConsumer.`position(TopicPartition partition, Handler<AsyncResult<Long>> handler)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Resume specified partition which have been paused with pause.
    `Single<Void>` | KafkaConsumer.`rxAssign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `Single<Long>` | KafkaConsumer.`rxBeginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `Single<OffsetAndMetadata>` | KafkaConsumer.`rxCommitted(TopicPartition topicPartition)` Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Single<Long>` | KafkaConsumer.`rxEndOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `Single<OffsetAndTimestamp>` | KafkaConsumer.`rxOffsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `Single<Void>` | KafkaConsumer.`rxPause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `Single<Long>` | KafkaConsumer.`rxPosition(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `Single<Void>` | KafkaConsumer.`rxResume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `Single<Void>` | KafkaConsumer.`rxSeek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `Single<Void>` | KafkaConsumer.`rxSeekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `Single<Void>` | KafkaConsumer.`rxSeekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset, Handler<AsyncResult<Void>> completionHandler)` Overrides the fetch offsets that the consumer will use on the next poll.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partition.

    Method parameters in io.vertx.rxjava.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`assignment(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions currently assigned to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are assigned to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are revoked to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Suspend fetching from the requested partitions.
    `void` | KafkaConsumer.`paused(Handler<AsyncResult<Set<TopicPartition>>> handler)` Get the set of partitions that were previously paused by a call to pause(Set).
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `KafkaConsumer<K,V>` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Resume specified partitions which have been paused with pause.
    `Single<Void>` | KafkaConsumer.`rxAssign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `Single<Void>` | KafkaConsumer.`rxPause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `Single<Void>` | KafkaConsumer.`rxResume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `Single<Void>` | KafkaConsumer.`rxSeekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `Single<Void>` | KafkaConsumer.`rxSeekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the first offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `KafkaConsumer<K,V>` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions, Handler<AsyncResult<Void>> completionHandler)` Seek to the last offset for each of the given partitions.

  - ### Uses of TopicPartition in io.vertx.rxjava3.kafka.admin

    Method parameters in io.vertx.rxjava3.kafka.admin with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Completable` | KafkaAdminClient.`deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.
    `Completable` | KafkaAdminClient.`rxDeleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions)` Delete committed offsets for a set of partitions in a consumer group.

  - ### Uses of TopicPartition in io.vertx.rxjava3.kafka.client.consumer

    Methods in io.vertx.rxjava3.kafka.client.consumer that return types with arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Single<Set<TopicPartition>>` | KafkaConsumer.`assignment()` Get the set of partitions currently assigned to this consumer.
    `Single<Set<TopicPartition>>` | KafkaConsumer.`paused()` Get the set of partitions that were previously paused by a call to pause(Set).
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxAssignment()` Get the set of partitions currently assigned to this consumer.
    `Single<Set<TopicPartition>>` | KafkaConsumer.`rxPaused()` Get the set of partitions that were previously paused by a call to pause(Set).

    Methods in io.vertx.rxjava3.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Completable` | KafkaConsumer.`assign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `Single<Long>` | KafkaConsumer.`beginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `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<Long>` | KafkaConsumer.`endOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `Single<OffsetAndTimestamp>` | KafkaConsumer.`offsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `Completable` | KafkaConsumer.`pause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `Single<Long>` | KafkaConsumer.`position(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `Completable` | KafkaConsumer.`resume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `Completable` | KafkaConsumer.`rxAssign(TopicPartition topicPartition)` Manually assign a partition to this consumer.
    `Single<Long>` | KafkaConsumer.`rxBeginningOffsets(TopicPartition topicPartition)` Get the first offset for the given partitions.
    `Single<OffsetAndMetadata>` | KafkaConsumer.`rxCommitted(TopicPartition topicPartition)` Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Single<Long>` | KafkaConsumer.`rxEndOffsets(TopicPartition topicPartition)` Get the last offset for the given partition.
    `Single<OffsetAndTimestamp>` | KafkaConsumer.`rxOffsetsForTimes(TopicPartition topicPartition, Long timestamp)` Look up the offset for the given partition by timestamp.
    `Completable` | KafkaConsumer.`rxPause(TopicPartition topicPartition)` Suspend fetching from the requested partition.
    `Single<Long>` | KafkaConsumer.`rxPosition(TopicPartition partition)` Get the offset of the next record that will be fetched (if a record with that offset exists).
    `Completable` | KafkaConsumer.`rxResume(TopicPartition topicPartition)` Resume specified partition which have been paused with pause.
    `Completable` | KafkaConsumer.`rxSeek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `Completable` | KafkaConsumer.`rxSeekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `Completable` | KafkaConsumer.`rxSeekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.
    `Completable` | KafkaConsumer.`seek(TopicPartition topicPartition, long offset)` Overrides the fetch offsets that the consumer will use on the next poll.
    `Completable` | KafkaConsumer.`seekToBeginning(TopicPartition topicPartition)` Seek to the first offset for each of the given partition.
    `Completable` | KafkaConsumer.`seekToEnd(TopicPartition topicPartition)` Seek to the last offset for each of the given partition.

    Method parameters in io.vertx.rxjava3.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `Completable` | KafkaConsumer.`assign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are assigned to the consumer
    `KafkaConsumer<K,V>` | KafkaConsumer.`partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)` Set the handler called when topic partitions are revoked to the consumer
    `Completable` | KafkaConsumer.`pause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `Completable` | KafkaConsumer.`resume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `Completable` | KafkaConsumer.`rxAssign(Set<TopicPartition> topicPartitions)` Manually assign a list of partition to this consumer.
    `Completable` | KafkaConsumer.`rxPause(Set<TopicPartition> topicPartitions)` Suspend fetching from the requested partitions.
    `Completable` | KafkaConsumer.`rxResume(Set<TopicPartition> topicPartitions)` Resume specified partitions which have been paused with pause.
    `Completable` | KafkaConsumer.`rxSeekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `Completable` | KafkaConsumer.`rxSeekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.
    `Completable` | KafkaConsumer.`seekToBeginning(Set<TopicPartition> topicPartitions)` Seek to the first offset for each of the given partitions.
    `Completable` | KafkaConsumer.`seekToEnd(Set<TopicPartition> topicPartitions)` Seek to the last offset for each of the given partitions.

Copyright © 2023 Eclipse. All rights reserved.