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