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

4ngedf3f 于 2021-06-08 发布在 Kafka

关注(0)|答案(1)|浏览(378)

我使用python-kafka的simpleconsumer来收听kafka broker中的一个主题。kafka代理正在主机名为broker\u host的计算机上运行。现在，simpleconsumer从broker主机请求主题元数据以获取一个tuple

(Broker metadata, Topic metadata)

代理元数据如下所示：，

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

理想情况下，主机值必须是broker\u host( hostname shell cmd确认）但它是本地主机。。。
``主题的代理元数据如何进入kafka系统？显然，这破坏了系统，因为我的消费者试图连接到其本地主机上的9092。

1条答案

这看起来像你的经纪人广告本身不正确。
你经纪人的电话里有一条线 server.properties :


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

您应该取消对它的注解，并设置消费者可路由的值，然后重新启动代理。