kafka_consumer_factory.py

async def callback_sessions(msg, topic):
  pass
  
def consumer_factory():
  for t in topics:
    yield AsyncJafkaConsumer(topic=t, ..., callback=partial(callback_sessions, topic=t))

def run():
  for c in consumer_factory():
    asyncio.ensure_future(c.consume())
  
  loop = asyncio.get_event_loop()
  loop.run_forever()