'Check FetchResponses for topic authorization failures.
Raises:
TopicAuthorizationFailedError'

def _raise_if_unauthorized_topics(self):

    if self._unauthorized_topics:
        topics = set(self._unauthorized_topics)
        self._unauthorized_topics.clear()
        raise Errors.TopicAuthorizationFailedError(topics)
