我启动一个 docker 容器来运行 Kafka 服务器
docker run -p 2181:2181 -p 9092:9092 --env ADVERTISED_HOST=192.168.99.100 --env ADVERTISED_PORT=9092 spotify/kafka
我找到了 Docker 容器的 IP 地址。这是 172.17.0.2，我可以 ping 这个地址。
现在我想要一个发送消息的生产者：
from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='172.17.0.2:9092')
for i in range(100):
producer.send('foobar', b'hola')
producer.close()
然而这给出了：
kafka.errors.KafkaTimeoutError：KafkaTimeoutError：60.0 秒后无法更新元数据。
如何解决这个问题？
有同样的错误，但因为我的主题名称不正确/设置，与python_菜鸟 https://stackoverflow.com/questions/48261501/kafka-errors-kafkatimeouterror-kafkatimeouterror-failed-to-update-metadata-aft#comment92849412_48261501.
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)
