aio-libs / aio-libs/aiokafka

kafka consumer never reconnects

未關閉
#876 3 則留言 3 個 reaction 已指派 0 人 在 GitHub 檢視
主要語言
Python
星號
1.4k
分支
269
平均合併
1 天 1 小時
30 天內合併 PR
6

描述

**Describe the bug**
to the best of my knowledge, the consumer is _**somehow**_ dropping a connection to the kakfa brokers, and when it tries to reconnect it also seems to completely block the active event loop :(

heres how the logs look on the api:
```
2023-02-04 22:31:05,694 level=ERROR [client._get_conn:460] Unable connect to node with id 4:
2023-02-04 22:31:18,166 level=ERROR [client._get_conn:460] Unable connect to node with id 1:
2023-02-04 22:32:55,445 level=ERROR [client._get_conn:460] Unable connect to node with id 5:
2023-02-04 22:33:35,451 level=ERROR [client._get_conn:460] Unable connect to node with id 6:
2023-02-04 22:34:15,457 level=ERROR [client._get_conn:460] Unable connect to node with id 4:
2023-02-04 22:34:55,462 level=ERROR [client._get_conn:460] Unable connect to node with id 3:
2023-02-04 22:35:35,468 level=ERROR [client._get_conn:460] Unable connect to node with id 2:
2023-02-04 22:36:58,228 level=ERROR [client._get_conn:460] Unable connect to node with id 2:
2023-02-04 22:37:38,237 level=ERROR [client._get_conn:460] Unable connect to node with id 1:
2023-02-04 22:38:18,242 level=ERROR [client._get_conn:460] Unable connect to node with id 6:
2023-02-04 22:38:58,248 level=ERROR [client._get_conn:460] Unable connect to node with id 4:
2023-02-04 22:39:38,254 level=ERROR [client._get_conn:460] Unable connect to node with id 3:
```

**Expected behaviour**

The consumer should be able to recover and reconnect to the brokers, but it does not appear to be doing so.

**Environment (please complete the following information):**
- aiokafka version (`python -c "import aiokafka; print(aiokafka.__version__)"`): aiokafka==0.7.2
- kafka-python version (`python -c "import kafka; print(kafka.__version__)"`): kafka-python==2.0.2
- Kafka Broker version (`kafka-topics.sh --version`):
- Other information (Confluent Cloud version, etc.):

貢獻指南

開啟貢獻指南

評估

這個 Issue 還沒有評估資料。

把新 issue 寄到你的電子郵件信箱

精選適合新手參與的 GitHub issue 摘要。