'Suspend fetching from the requested partitions.
Future calls to :meth:`~kafka.KafkaConsumer.poll` will not return any
records from these partitions until they have been resumed using
:meth:`~kafka.KafkaConsumer.resume`.
Note: This method does not affect partition subscription. In particular,
it does not cause a group rebalance when automatic assignment is used.
Arguments:
*partitions (TopicPartition): Partitions to pause.'

def pause(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('Pausing    partition    %s', partition)
        self._subscription.pause(partition)
