aio-libs / aio-libs/aiokafka

kafka consumer never reconnects

オープン
#876 コメント 3 件 リアクション 3 件 担当者 0 名 GitHub で見る
主要言語
Python
スター
1.4k
フォーク
269
平均マージ
1日 1時間
マージ済み PR(30日)
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 を短くまとめたダイジェスト。