aio-libs / aio-libs/aiokafka

auto_commit is not failure safe

Aperta
#211 2 commenti 2 reazioni 0 assegnatari Vedi su GitHub
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.

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.