无法从我的本地主机连接到 Kafka 服务器答案

【问题标题】：Unable to connect to Kakfa Server from my localhost无法从我的本地主机连接到 Kafka 服务器
【发布时间】：2018-03-28 22:48:53
【问题描述】：

我的 Kafka 服务器在其他系统上运行。我试图通过提供运行 Kafka 服务器的机器的代理 url 从我的本地机器上运行客户端。但不幸的是，我无法连接到 kafka 服务器。

server.properties 文件具有以下属性：

    group.initial.rebalance.delay.ms=0
    listeners=SASL_PLAINTEXT://localhost:9093
    advertised.listeners=SASL_PLAINTEXT://localhost:9093
    #advertised.listeners=SASL_PLAINTEXT://10.97.123.52:9093
    security.inter.broker.protocol=SASL_PLAINTEXT
    sasl.mechanism.inter.broker.protocol=PLAIN
    sasl.enabled.mechanisms=PLAIN

从我的本地机器上运行我的客户端时，我正在传递服务器机器的代理 url，但无法连接:(。有人可以帮忙解决这个问题吗？

【问题讨论】：

标签： apache-kafka

【解决方案1】：

有点简化，但是……客户端首先连接到 bootstrap 服务器以获取元数据。基于该元数据，它将打开另一个到代理的 TCP 连接，该代理是客户端想要与之交谈的主题/分区的领导者。

第一个连接是根据您设置的引导服务器地址完成的。第二个连接被打开到来自元数据的地址。在您的情况下，元数据将包含来自advertised.listeners 字段的地址，即localhost。所以客户端会尝试连接到localhost:9093 而不是你的代理。因此，您需要设置advertised.listeners 以使用代理对客户端可见的地址。（这可能是您的配置示例中注释掉的那一行？）

您还将listener 字段设置为仅收听localhost。因此无法从外部 IP 地址访问它。您必须更改它以侦听外部 IP 地址。很可能将其设置为以下值（即没有localhost）应该会有所帮助：

listeners=SASL_PLAINTEXT://:9093

【讨论】：

嗨，Jakub，感谢您提供的信息。我已经更新了我的服务器机器的名称和 ads.listener 中的端口号并重新启动了服务器。现在它给我的错误是：无法建立到节点 0 的连接。经纪人可能不可用。
另外，我可以在哪里设置引导服务器以及它的值应该是多少。我可以在生产者和消费者属性文件中看到引导服务器。是我可以设置的地方吗？
您说您使用的是“您的客户”。如果那是 Apache Kafka Java 客户端，那么您应该在属性文件中设置 ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG 属性，并在创建它时传递给消费者/生产者。对于不同语言的客户端，它的调用/设置可能不同。
至于“无法建立连接”，没有确切的日志很难猜测。但是您总是可以从尝试打开到 IP 地址和端口的 telnet 连接开始。我在您的配置中注意到您的侦听器设置为 localhost。您可能也应该更改它 - 如果您想从外部连接，它应该侦听所有接口，而不仅仅是在 localhost 上。我将使用该信息更新答案。
group.initial.rebalance.delay.ms=0 listeners=SASL_PLAINTEXT://:9093 #advertised.listeners=SASL_PLAINTEXT://localhost:9093 advertised.listeners=SASL_PLAINTEXT://：9093 security.inter.broker.protocol=SASL_PLAINTEXT sasl.mechanism.inter.broker.protocol=PLAIN sasl.enabled.mechanisms=PLAIN