元数据响应 - 代理主机名错误

Question

我使用python-kafka的SimpleConsumer在kafka broker中收听一个话题。 Kafka 代理在主机名为 BROKER_HOST 的机器上 运行。 现在，SimpleConsumer 从代理 BROKER_HOST 为主题 TOPIC 请求主题元数据并获取元组

   (Broker metadata, Topic metadata)

代理元数据为，

 {0: BrokerMetadata(nodeId=0, host='localhost', port=9092)}

理想情况下，主机值必须是 BROKER_HOST（hostname shell cmd 确认）但它是本地主机...

``topic的broker metadata如何进入kafka系统？显然，这破坏了系统，因为我的消费者试图连接到其本地主机上的 9092。

Answer 1

您的经纪商似乎错误地宣传了自己。

您的经纪人 server.properties 中有一行：

#advertised.host.name=<hostname routable by clients>

您应该取消注释并设置消费者可路由的值并重新启动您的代理。