abstract fun assignment(handler: Handler<AsyncResult<MutableSet<TopicPartition>>>): KafkaConsumer<K, V>
Get the set of partitions currently assigned to this consumer.
handler - handler called on operation completed
Return
current KafkaConsumer instance