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