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

# rxSubscribe

`open fun rxSubscribe(topic: String): Single<Void>`

Subscribe to the given topic to get dynamically assigned partitions.

### Parameters

`topic` - topic to subscribe to

Return

`open fun rxSubscribe(topics: MutableSet<String>): Single<Void>`

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

### Parameters

`topics` - topics to subscribe to

Return