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