aiokafka icon indicating copy to clipboard operation
aiokafka copied to clipboard

I don't understand how call async function in add_done_callback after commit done. Maybe show it? [QUESTION]

Open worlak2 opened this issue 4 years ago • 0 comments
trafficstars

fut = loop.create_task(consumer.commit()) fut.add_done_callback(on_commit_done)

worlak2 avatar Jul 06 '21 19:07 worlak2