vertx / io.vertx.rxjava.kafka.client.consumer / KafkaConsumer / rxAssign

# rxAssign

`open fun rxAssign(topicPartition: TopicPartition): Single<Void>`

Manually assign a partition to this consumer.

Due to internal buffering of messages, when reassigning the old partition may remain in effect (as observed by the record handler)} until some time after the given `completionHandler` is called. In contrast, the once the given `completionHandler` is called the `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#batchHandler` will only see messages consistent with the new partition.

### Parameters

`topicPartition` - partition which want assigned

Return

`open fun rxAssign(topicPartitions: MutableSet<TopicPartition>): Single<Void>`

Manually assign a list of partition to this consumer.

Due to internal buffering of messages, when reassigning the old set of partitions may remain in effect (as observed by the record handler)} until some time after the given `completionHandler` is called. In contrast, the once the given `completionHandler` is called the `io.vertx.rxjava.kafka.client.consumer.KafkaConsumer#batchHandler` will only see messages consistent with the new set of partitions.

### Parameters

`topicPartitions` - partitions which want assigned

Return