'Resume fetching from the specified (paused) partitions.
Arguments:
*partitions (TopicPartition): Partitions to resume.'

def resume(self, *partitions):

    if (not all([isinstance(p, TopicPartition) for p in partitions])):
        raise TypeError('partitions    must    be    TopicPartition    namedtuples')
    for partition in partitions:
        log.debug('Resuming    partition    %s', partition)
        self._subscription.resume(partition)
