## 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 | Description
    --- | --- | ---
    `Future<Map<TopicPartition,​org.apache.kafka.clients.admin.DeletedRecords>>` | KafkaAdminClient.`deleteRecords​(Map<TopicPartition,​org.apache.kafka.clients.admin.RecordsToDelete> recordsToDelete)` | Delete records from a topic partition.
    `Set<TopicPartition>` | MemberAssignment.`getTopicPartitions()` |
    `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.
    `Future<Map<TopicPartition,​ListOffsetsResultInfo>>` | KafkaAdminClient.`listOffsets​(Map<TopicPartition,​OffsetSpec> topicPartitionOffsets)` | List the offsets available for a set of partitions.
    `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 | Description
    --- | --- | ---
    `Future<Void>` | KafkaAdminClient.`alterConsumerGroupOffsets​(String groupId, Map<TopicPartition,​OffsetAndMetadata> offsets)` | Alter committed offsets for a set of partitions in a consumer group.
    `Future<Void>` | KafkaAdminClient.`deleteConsumerGroupOffsets​(String groupId, Set<TopicPartition> partitions)` | 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)` | Delete records from a topic partition.
    `Future<Map<TopicPartition,​ListOffsetsResultInfo>>` | KafkaAdminClient.`listOffsets​(Map<TopicPartition,​OffsetSpec> topicPartitionOffsets)` | 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 | 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 | 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 | 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 | Description
    --- | --- | ---
    `Future<Set<TopicPartition>>` | KafkaConsumer.`assignment()` | Get the set of partitions currently assigned to this consumer.
    `Future<Map<TopicPartition,​Long>>` | KafkaConsumer.`beginningOffsets​(Set<TopicPartition> topicPartitions)` | 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.
    `Future<Map<TopicPartition,​Long>>` | KafkaConsumer.`endOffsets​(Set<TopicPartition> topicPartitions)` | Get the last offset for the given partitions.
    `Future<Map<TopicPartition,​OffsetAndTimestamp>>` | KafkaConsumer.`offsetsForTimes​(Map<TopicPartition,​Long> topicPartitionTimestamps)` | Look up the offsets for the given partitions by timestamp.
    `Future<Set<TopicPartition>>` | KafkaConsumer.`paused()` | Get the set of partitions that were previously paused by a call to pause(Set).

    Methods in io.vertx.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | KafkaConsumer.`assign​(TopicPartition topicPartition)` | Manually assign a partition to this consumer.
    `Future<Long>` | KafkaConsumer.`beginningOffsets​(TopicPartition topicPartition)` | Get the first offset for the given partitions.
    `Future<OffsetAndMetadata>` | KafkaConsumer.`committed​(TopicPartition topicPartition)` | Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Future<Long>` | KafkaConsumer.`endOffsets​(TopicPartition topicPartition)` | Get the last offset for the given partition.
    `Future<OffsetAndTimestamp>` | KafkaConsumer.`offsetsForTimes​(TopicPartition topicPartition, Long timestamp)` | Look up the offset for the given partition by timestamp.
    `Future<Void>` | KafkaConsumer.`pause​(TopicPartition topicPartition)` | Suspend fetching from the requested partition.
    `Future<Long>` | KafkaConsumer.`position​(TopicPartition partition)` | 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.
    `Future<Void>` | KafkaConsumer.`seek​(TopicPartition topicPartition, long offset)` | 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.
    `Future<Void>` | KafkaConsumer.`seekToBeginning​(TopicPartition topicPartition)` | 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.

    Method parameters in io.vertx.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | KafkaConsumer.`assign​(Set<TopicPartition> topicPartitions)` | Manually assign a list of partition to this consumer.
    `Future<Map<TopicPartition,​Long>>` | KafkaConsumer.`beginningOffsets​(Set<TopicPartition> topicPartitions)` | 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.
    `Future<Map<TopicPartition,​Long>>` | KafkaConsumer.`endOffsets​(Set<TopicPartition> topicPartitions)` | Get the last offset for the given partitions.
    `Future<Map<TopicPartition,​OffsetAndTimestamp>>` | KafkaConsumer.`offsetsForTimes​(Map<TopicPartition,​Long> topicPartitionTimestamps)` | 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.
    `Future<Void>` | KafkaConsumer.`resume​(Set<TopicPartition> topicPartitions)` | 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.
    `Future<Void>` | KafkaConsumer.`seekToEnd​(Set<TopicPartition> topicPartitions)` | 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 | Description
    --- | --- | ---
    `Future<Void>` | 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.reactivex.kafka.client.consumer

    Methods in io.vertx.reactivex.kafka.client.consumer that return types with arguments of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Set<TopicPartition>>` | KafkaConsumer.`assignment()` | Get the set of partitions currently assigned to this consumer.
    `Future<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.reactivex.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | KafkaConsumer.`assign​(TopicPartition topicPartition)` | Manually assign a partition to this consumer.
    `Future<Long>` | KafkaConsumer.`beginningOffsets​(TopicPartition topicPartition)` | Get the first offset for the given partitions.
    `Future<OffsetAndMetadata>` | KafkaConsumer.`committed​(TopicPartition topicPartition)` | Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Future<Long>` | KafkaConsumer.`endOffsets​(TopicPartition topicPartition)` | Get the last offset for the given partition.
    `Future<OffsetAndTimestamp>` | KafkaConsumer.`offsetsForTimes​(TopicPartition topicPartition, Long timestamp)` | Look up the offset for the given partition by timestamp.
    `Future<Void>` | KafkaConsumer.`pause​(TopicPartition topicPartition)` | Suspend fetching from the requested partition.
    `Future<Long>` | KafkaConsumer.`position​(TopicPartition partition)` | 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.
    `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.`rxSeek​(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)` | 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.
    `Future<Void>` | KafkaConsumer.`seek​(TopicPartition topicPartition, long offset)` | 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.
    `Future<Void>` | KafkaConsumer.`seekToBeginning​(TopicPartition topicPartition)` | 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.

    Method parameters in io.vertx.reactivex.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | 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
    `Future<Void>` | KafkaConsumer.`pause​(Set<TopicPartition> topicPartitions)` | Suspend fetching from the requested partitions.
    `Future<Void>` | 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.
    `Future<Void>` | KafkaConsumer.`seekToBeginning​(Set<TopicPartition> topicPartitions)` | 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.

  - ### 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 | Description
    --- | --- | ---
    `Future<Void>` | KafkaAdminClient.`deleteConsumerGroupOffsets​(String groupId, Set<TopicPartition> partitions)` | 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 | Description
    --- | --- | ---
    `Future<Set<TopicPartition>>` | KafkaConsumer.`assignment()` | Get the set of partitions currently assigned to this consumer.
    `Future<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.rxjava.kafka.client.consumer with parameters of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | KafkaConsumer.`assign​(TopicPartition topicPartition)` | Manually assign a partition to this consumer.
    `Future<Long>` | KafkaConsumer.`beginningOffsets​(TopicPartition topicPartition)` | Get the first offset for the given partitions.
    `Future<OffsetAndMetadata>` | KafkaConsumer.`committed​(TopicPartition topicPartition)` | Get the last committed offset for the given partition (whether the commit happened by this process or another).
    `Future<Long>` | KafkaConsumer.`endOffsets​(TopicPartition topicPartition)` | Get the last offset for the given partition.
    `Future<OffsetAndTimestamp>` | KafkaConsumer.`offsetsForTimes​(TopicPartition topicPartition, Long timestamp)` | Look up the offset for the given partition by timestamp.
    `Future<Void>` | KafkaConsumer.`pause​(TopicPartition topicPartition)` | Suspend fetching from the requested partition.
    `Future<Long>` | KafkaConsumer.`position​(TopicPartition partition)` | 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.
    `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.`rxSeek​(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)` | 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.
    `Future<Void>` | KafkaConsumer.`seek​(TopicPartition topicPartition, long offset)` | 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.
    `Future<Void>` | KafkaConsumer.`seekToBeginning​(TopicPartition topicPartition)` | 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.

    Method parameters in io.vertx.rxjava.kafka.client.consumer with type arguments of type TopicPartition
    Modifier and Type | Method | Description
    --- | --- | ---
    `Future<Void>` | 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
    `Future<Void>` | KafkaConsumer.`pause​(Set<TopicPartition> topicPartitions)` | Suspend fetching from the requested partitions.
    `Future<Void>` | KafkaConsumer.`resume​(Set<TopicPartition> topicPartitions)` | 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.
    `Future<Void>` | KafkaConsumer.`seekToBeginning​(Set<TopicPartition> topicPartitions)` | 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.

  - ### 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 | 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 | 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 | 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.`rxSeek​(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)` | 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.`seek​(TopicPartition topicPartition, OffsetAndMetadata offsetAndMetadata)` | 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 | 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.