def pimap(iterable, function, *args, **kwargs):
    from multiprocessing import Pool
    global worker
    def worker(x):
        return function(x, *args, **kwargs)
    return Pool(processes=None).imap(worker, iterable)

#--- READ-ONLY DICTIONARY --------------------------------------------------------------------------
Fetch data from assigned topics / partitions.
dataset/ETHPy150Open clips/pattern/pattern/vector/__init__.py/pimap--crossover with--dataset/ETHPy150Open dpkp/kafka-python/kafka/consumer/group.py/KafkaConsumer.poll