def assignment(self):
        return self._subscription.assigned_partitions()
Get the TopicPartitions currently assigned to this consumer.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.assignment