def init_fetches(self):
        # We need to be careful when creating fetch records during iteration
        # so we verify that there are no records in the deque, or in an
        # iterator
        if self._records or self._iterator:
            log.debug('Skipping init_fetches because there are unconsumed'
                      ' records internally')
            return []
        return self._init_fetches()
Send FetchRequests asynchronously for all assigned partitions.
dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/fetcher.py/Fetcher.init_fetches