open fun rxAssignment(): Single<MutableSet<TopicPartition>>
Get the set of partitions currently assigned to this consumer.
Return