vertx / io.vertx.kafka.client.consumer / KafkaReadStream / subscribe

subscribe

abstract fun subscribe(topics: MutableSet<String>): KafkaReadStream<K, V>

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

Parameters

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.

Parameters

topics - topics to subscribe to

completionHandler - handler called on operation completed

Return
current KafkaReadStream instance