aio-libs / aio-libs/aiokafka

NodeNotReadyError prevents publisher from sending

Open
#642 3 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.