abstract fun partitionsRevokedHandler(handler: Handler<MutableSet<TopicPartition>>): KafkaReadStream<K, V>
Set the handler called when topic partitions are revoked to the consumer
handler - handler called on revoked topic partitions
Return
current KafkaReadStream instance