'Callback that runs on each assignment.
This method can be used to update internal state, if any, of the
partition assignor.
Arguments:
assignment (MemberAssignment): the member\'s assignment'

@abc.abstractmethod
def on_assignment(self, assignment):

    pass
