def ensure_active_group(self, timeout_ms=None):
        """Ensure that the group is active (i.e. joined and synced)

        Keyword Arguments:
            timeout_ms (numeric, optional): Maximum number of milliseconds to
                block waiting to join group. Default: None.

        Returns: True if group initialized before timeout_ms, else False
        """
        if self.config['api_version'] < (0, 9):
            raise Errors.UnsupportedVersionError('Group Coordinator APIs require 0.9+ broker')
        timer = Timer(timeout_ms)
        if not self.ensure_coordinator_ready(timeout_ms=timer.timeout_ms):
            return False
        self._start_heartbeat_thread()
        return self.join_group(timeout_ms=timer.timeout_ms)
Ensure that the group is active (i.e. joined and synced)

        Keyword Arguments:
            timeout_ms (numeric, optional): Maximum number of milliseconds to
                block waiting to join group. Default: None.

        Returns: True if group initialized before timeout_ms, else False
        
kafka/coordinator/base.py