Consumers start hanging with AIOKafkaConnection._read() Cancelled Error
Aperta
- Lingua principale
- Python
- Stelle
- 1.4k
- Fork
- 269
- Merge medio
- 1g 1h
- PR unite (30g)
- 6
Descrizione
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`
Guida per i contributori
Apri la guida per i contributori
Valutazione
Questa issue non è ancora stata valutata.