我使用python-kafka的SimpleConsumer来收听kafka经纪人的话题 . Kafka代理正在一台主机名为BROKER_HOST的机器上运行 . 现在，SimpleConsumer从代理BROKER_HOST请求主题元数据以获取主题TOPIC并获取元组
(Broker metadata, Topic metadata)
经纪人元数据来自，
{0: BrokerMetadata(nodeId=0, host='localhost', port=9092)}
理想情况下，主机值必须是BROKER_HOST（ hostname shell cmd确认它）但它是localhost ...
``一个主题的代理元数据如何进入kafka系统？显然，这会破坏系统，因为我的消费者试图在其localhost上连接到9092 .
1 回答
这看起来像您的经纪人错误地宣传自己 .
有's a line in your broker' s
server.properties：您应取消注释并设置消费者可路由的值并重新启动代理 .