aio-libs / aio-libs/aiokafka

[QUESTION] How to close connection if Kafka server isn't responding?

オープン
#1,013 コメント 0 件 リアクション 0 件 担当者 0 名 GitHub で見る
question
主要言語
Python
スター
1.4k
フォーク
269
平均マージ
1日 1時間
マージ済み PR(30日)
6

説明

Hi!
I want to close both a producer and consumer when Kafka server isn't responding anymore.
If I do
```python
await producer.stop()
```
```python
await consumer.stop()
```
It will try to flush, but since the server isn't online, it won't close.

Any suggestions?

コントリビューションガイド

コントリビューションガイドを開く

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。