kafka.errors.KafkaTimeoutError: KafkaTimeoutError: 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: Failed to update metadata after 60.0 secs.

如何解决这个问题？

Answer 1

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