auto_commit is not failure safe
Aperta
- Lingua principale
- Python
- Stelle
- 1.4k
- Fork
- 269
- Merge medio
- 1g 1h
- PR unite (30g)
- 6
Descrizione
When processing an entry fails auto_commit will mark message as processed including the failed one.
Simple example:
```python
async for msg in consumer:
1/0
```
Does consumes one message while it should have consumed none.
One possible solution would be to mark a message for auto_commit on `__anext__` on the iteration after the respective item.
Guida per i contributori
Apri la guida per i contributori
Valutazione
Questa issue non è ancora stata valutata.