aiokafka
aiokafka copied to clipboard
I don't understand how call async function in add_done_callback after commit done. Maybe show it? [QUESTION]
trafficstars
fut = loop.create_task(consumer.commit()) fut.add_done_callback(on_commit_done)