Publish messages to None topic with AIOKafkaProducer
オープン
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 はまだ評価されていません。