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

rxSubscribe

open fun rxSubscribe(topic: String): Completable

Subscribe to the given topic to get dynamically assigned partitions.

Parameters

topic - topic to subscribe to

Return

open fun rxSubscribe(topics: MutableSet<String>): Completable

Subscribe to the given list of topics to get dynamically assigned partitions.

Parameters

topics - topics to subscribe to

Return