avro_consumer_batch.py

import asyncio

consumer = DeserializingConsumer(consumer_conf)
consumer.subscribe("my_topic")

async def batch_poll(consumer):
    with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
        future = executor.submit(consumer.poll)
        awaitable = await asyncio.wrap_future(future)
        return awaitable

msgs: list = await asyncio.gather(*(batch_poll() for _ in range(10)))