suspend fun <K, V> KafkaConsumer<K, V>.subscriptionAwait(): Set<String>
Get the current subscription.
handler - handler called on operation completed
handler
Returncurrent KafkaConsumer instance *