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

Question

我使用 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（hostnameshell cmd 确认）但它是 localhost...

``主题的代理元数据如何进入 kafka 系统？显然，这会破坏系统，因为我的消费者尝试连接到其本地主机上的 9092。

score 2 · Accepted Answer

这看起来像您的经纪人错误地宣传自己。

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

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

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

1 回答 1