Consumers start hanging with AIOKafkaConnection._read() Cancelled Error
未关闭
- 主要语言
- Python
- 星标
- 1.4k
- 派生
- 269
- 平均合并
- 1 天 1 小时
- 30 天内合并 PR
- 6
描述
The consumers start hanging at some point with the following error being logged:
```
[2017-11-07 18:17:47,547: ERROR] Task exception was never retrieved
future: exception=CancelledError()>
```
What might be causing the error? Should we be crashing the consumer upon getting the error?
This is with `aiokafka==0.3.1`
贡献指南
评估
这个 Issue 还没有评估数据。