abstract fun subscribe(topics: MutableSet<String>): KafkaReadStream<K, V>
Subscribe to the given list of topics to get dynamically assigned partitions.
topics - topics to subscribe to
Return
current KafkaReadStream instance
abstract fun subscribe(topics: MutableSet<String>, completionHandler: Handler<AsyncResult<Void>>): KafkaReadStream<K, V>
Subscribe to the given list of topics to get dynamically assigned partitions.
topics - topics to subscribe to
completionHandler - handler called on operation completed
Return
current KafkaReadStream instance