我启动一个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_noob相同。
关于docker - kafka.errors.KafkaTimeoutError : KafkaTimeoutError: Failed to update metadata after 60. 0秒，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/48261501/