Connection errors are spamming
- Linguagem predominante
- Python
- Estrelas
- 1.4k
- Forks
- 269
- Merge médio
- 1d 1h
- PRs com merge (30d)
- 6
Descrição
**Describe the bug**
Whenever AIOKafkaConsumer (maybe Producer too) loses connection to Kafka, 17 identical error logs are outputted.
```
Failed fetch messages from 1: NodeNotReadyError: Attempt to send a request to node which is not ready (node id 1).
Unable connect to node with id 1: [Errno 111] Connect call failed ('172.19.0.8', 29092)
Unable to update metadata from [1]
```
**Expected behaviour**
Only 1 log
**Environment (please complete the following information):**
- aiokafka version: 0.10.0
- Kafka Broker version: 7.6.1-ccs
**Reproducible example**
```python
from aiokafka import AIOKafkaConsumer
async def run_consumer():
async with AIOKafkaConsumer(
"test",
bootstrap_servers="kafka:29092",
) as consumer:
async for message in consumer:
print(message.value)
if __name__ == "__main__":
import asyncio
loop = asyncio.get_event_loop()
loop.run_until_complete(run_consumer())
loop.close()
```
Guia de contribuição
Avaliação
Esta issue ainda não foi avaliada.