def __next__(self):
        if not self._iterator:
            self._iterator = self._message_generator()
        try:
            return next(self._iterator)
        except __HOLE__:
            self._iterator = None
            raise
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/fetcher.py/Fetcher.__next__