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