def fetchable_partitions(self):
        """Return ordered list of TopicPartitions that should be Fetched."""
        fetchable = list()
        for partition, state in six.iteritems(self.assignment):
            if state.is_fetchable():
                fetchable.append(partition)
        return fetchable
Return ordered list of TopicPartitions that should be Fetched.
kafka/consumer/subscription_state.py