shargan
Results
1
comments of
shargan
> One possible solution would be to mark a message for auto_commit on \_\_anext\_\_ on the iteration after the respective item. ``` def next_message_that_matters(consumer, match): async for msg in consumer:...