open fun rxSubscribe(topic: String): Single<Void>
Subscribe to the given topic to get dynamically assigned partitions.
Return
open fun rxSubscribe(topics: MutableSet<String>): Single<Void>
Subscribe to the given list of topics to get dynamically assigned partitions.
topics - topics to subscribe to
Return