@abc.abstractmethod
    def assign(self, cluster, members):
        pass
Perform group assignment given cluster metadata and member subscriptions
dataset/ETHPy150Open dpkp/kafka-python/kafka/coordinator/assignors/abstract.py/AbstractPartitionAssignor.assign