我正在使用Python 3.6编写Kafka producer,Python Kafka客户端版本是1.4.4。Kafka版本是:2.1.0和1.1.1(尝试两个版本),但是当我向producer编写消息时,抛出以下错误:
KafkaTimeoutError('Failed to update metadata after 60.0 secs.')
这是我的客户代码:
^{pr2}$这是我修改的服务器配置:
listeners=PLAINTEXT://10.142.0.2:9092
advertised.listeners=PLAINTEXT://10.142.0.2:9092
当使用脚本生成和使用消息时,它工作得很好!这是客户端跟踪输出:
D:\project\souce\pydolphin-service>D:/Programs/Python/Python37/python.exe d:/project/souce/pydolphin-service/dolphin/producer.py
Traceback (most recent call last):
File "d:/project/souce/pydolphin-service/dolphin/producer.py", line 14, in <module>
future = producer.send('my-topic', b'raw_bytes')
File "D:\Programs\Python\Python37\lib\site-packages\kafka\producer\kafka.py", line 555, in send
self._wait_on_metadata(topic, self.config['max_block_ms'] / 1000.0)
File "D:\Programs\Python\Python37\lib\site-packages\kafka\producer\kafka.py", line 682, in _wait_on_metadata
"Failed to update metadata after %.1f secs." % (max_wait,))
kafka.errors.KafkaTimeoutError: KafkaTimeoutError: Failed to update metadata after 60.0 secs.
我正在谷歌百度和yandex搜索。在
调整广告配置:
将NAT内部网络ip修改为公共网络ip。因为制作人会把消息发到这个地址。制作人只能向公众开放。在
你的开发箱和kafka服务器有防火墙吗?你能试试telnet mq服务器9092吗
相关问题 更多 >
编程相关推荐