docs: def pause(self, *partitions):
          """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.
          """
          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)