aio-libs / aio-libs/aiokafka

Publish messages to None topic with AIOKafkaProducer

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

説明

Hello,
If we try publish message into `None` topic there are some error messages:
```
Unable to request metadata from node with id 0: ConnectionError: Connection at localhost:9092 broken
Unable to update metadata from [0]
...
```

Code snippet to reproduce:
```python
import aiokafka
p = aiokafka.AIOKafkaProducer(bootstrap_servers=["localhost:9092"],
loop=loop)
loop.run_until_complete(p.start())
loop.run_until_complete(p.send_and_wait(None, b"sobaka"))
loop.run_until_complete(p.stop())
```
Packages versions:
```
aiokafka==0.4.0
kafka-python==1.3.5
```

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

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

評価

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

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

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