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

rxAssign

open fun rxAssign(topicPartition: TopicPartition): Completable

Manually assign a partition to this consumer.

Parameters

topicPartition - partition which want assigned

Return

open fun rxAssign(topicPartitions: MutableSet<TopicPartition>): Completable

Manually assign a list of partition to this consumer.

Parameters

topicPartitions - partitions which want assigned

Return