def assign(self, partitions):
        self._subscription.assign_from_user(partitions)
        self._client.set_topics([tp.topic for tp in partitions])
Manually assign a list of TopicPartitions to this consumer.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.assign