'Get the partitions that were previously paused using
:meth:`~kafka.KafkaConsumer.pause`.
Returns:
set: {partition (TopicPartition), ...}'

def paused(self):

    return self._subscription.paused_partitions()
