## 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.client.consumer |
  io.vertx.rxjava.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
    --- | ---
    `Set<TopicPartition>` | MemberAssignment.`getTopicPartitions()`

    Method parameters in io.vertx.kafka.admin with type arguments of type TopicPartition
    Modifier and Type | Method and Description
    --- | ---
    `MemberAssignment` | MemberAssignment.`setTopicPartitions(Set<TopicPartition> topicPartitions)` Set the list of topic partitions

    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 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, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `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, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `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, 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.
    `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.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.
    `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.
    `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.`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.
    `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
    `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.
    `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.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, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `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, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `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, 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.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, Handler<AsyncResult<Long>> handler)` Get the first offset for the given partitions.
    `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, Handler<AsyncResult<Long>> handler)` Get the last offset for the given partition.
    `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, 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.

Copyright © 2019 Eclipse. All rights reserved.