'Check whether the group should be rejoined
Returns:
bool: True if consumer should rejoin group, False otherwise'

def need_rejoin(self):

    return (self._subscription.partitions_auto_assigned() and (super(ConsumerCoordinator, self).need_rejoin() or self._subscription.needs_partition_assignment))
