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

# rxAssign

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

Manually assign a partition to this consumer.

### Parameters

`topicPartition` - partition which want assigned

Return

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

Manually assign a list of partition to this consumer.

### Parameters

`topicPartitions` - partitions which want assigned

Return