@abc.abstractmethod
    def on_assignment(self, assignment):
        pass
Callback that runs on each assignment.
dataset/ETHPy150Open dpkp/kafka-python/kafka/coordinator/assignors/abstract.py/AbstractPartitionAssignor.on_assignment