NodeNotReadyError prevents publisher from sending
- Dominant language
- Python
- Stars
- 1.4k
- Forks
- 269
- Avg merge
- 1d 1h
- Merged PRs (30d)
- 6
Description
**Describe the bug**
We received an alert from our error monitoring system. There are 3 log lines from `aiokafka` loggers at the time of the incident:
```
2020-07-04T18:06:27.135 - Unable connect to node with id 1:
2020-07-04T18:06:27.142 - Got error produce response: NodeNotReadyError: Attempt to send a request to node which is not ready (node id 1).
2020-07-04T18:06:27.218 - Authenticated as *** via PLAIN
```
The stacktrace points to:
```
...
File "grid/systems/kafka.py", line 70, in publish
await self.producer.send_and_wait(
File "aiokafka/producer/producer.py", line 452, in send_and_wait
return (await future)
```
**Expected behaviour**
Message sending is retried
**Environment (please complete the following information):**
- aiokafka version: 0.6.0
- kafka-python version: 2.0.1
- Other information: We are using Confluent Cloud
Contributor guide
Assessment
This issue has not been assessed yet.