Consumers start hanging with AIOKafkaConnection._read() Cancelled Error
Đang mở
- Ngôn ngữ chính
- Python
- Star
- 1.4k
- Fork
- 269
- Merge trung bình
- 1 ngày 1 giờ
- Pull request đã merge (30 ngày)
- 6
Mô tả
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`
Hướng dẫn đóng góp
Đánh giá
Issue này chưa được đánh giá.