aio-libs / aio-libs/aiokafka

Error logs are continuously printed when disconnected from Kafka

Aberta
#830 0 comentários 5 reações 0 responsáveis Ver no GitHub
enhancement
Linguagem predominante
Python
Estrelas
1.4k
Forks
269
Merge médio
1d 1h
PRs com merge (30d)
6

Descrição

```python
consumer_ = aiokafka.AIOKafkaConsumer(
*topics,
bootstrap_servers=f"192.168.1.100:9092",
)
await consumer_.start()
try:
async for msg in consumer_:
print(msg)
finally:
await consumer_.stop()
```
`aiokafka` outputs a lot of error logs when I disconnect from 192.168.1.100 :

```
ERROR | aiokafka.consumer.fetcher:_proc_fetch_request:658 - Failed fetch messages from 3: KafkaConnectionError: Connection at 10.64.73.35:9094 closed
ERROR | aiokafka.client:_get_conn:460 - Unable connect to node with id 3: [WinError 1232]
```

Guia de contribuição

Abrir o guia de contribuição

Avaliação

Esta issue ainda não foi avaliada.

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.