kafka.errors.KafkaTimeoutError:KafkaTimeoutError:60.0秒后无法更新元数据

问题描述

我启动一个docker容器来运行

I start a docker container to run a Kafka server with

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通此地址.

I find the IP address of the Docker container. This is 172.17.0.2 and I can ping this address.

现在我想要一个发送消息的生产者:

Now I want a producer that sends messages:

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秒后无法更新元数据.

However this gives:kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Failed to update metadata after 60.0 secs.

如何解决这个问题?

推荐答案

发生相同的错误，但是因为我的主题名称不正确/设置，与.

Had the same error but because my topic name wasn't right/set, same as python_noob.

这篇关于kafka.errors.KafkaTimeoutError:KafkaTimeoutError:60.0秒后无法更新元数据的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！