docker - kafka.errors.KafkaTimeoutError : KafkaTimeoutError: Failed to update metadata after 60. 0 秒

Question

我启动一个 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秒后无法更新元数据。

如何解决这个问题？

Answer 1

有同样的错误，但因为我的主题名称不正确/设置，与 python_noob 相同.