auto_commit is not failure safe
未关闭
- 主要语言
- Python
- 星标
- 1.4k
- 派生
- 269
- 平均合并
- 1 天 1 小时
- 30 天内合并 PR
- 6
描述
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.
贡献指南
评估
这个 Issue 还没有评估数据。