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

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()
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
void	KafkaAdminClient.deleteConsumerGroupOffsets(String groupId, Set<TopicPartition> partitions, Handler<AsyncResult<Void>> completionHandler) Delete committed offsets for a set of partitions in a consumer group.
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.
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 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.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, 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, 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.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, 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, 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.