无法使用 node-red 联系到 kafka 生产者答案

【问题标题】：Can't reach kafka producer with node-red无法使用 node-red 联系到 kafka 生产者
【发布时间】：2017-05-11 05:05:16
【问题描述】：

我已经在树莓派 3 上安装了 node-red 来从传感器收集数据，然后将它们存储在 kafka 中，但现在我遇到了 kafka 生产者节点的一些问题。我已经在我的笔记本电脑上设置了一个可以在控制台中正常工作的 kafka 服务器：如果我在 kafka 生产者控制台上发送消息，我会在消费者控制台上正确接收它。不幸的是，当我尝试在树莓上的节点红色的 kafka 生产者中注入时间戳时，服务器没有响应。

node-red 的调试页面显示：“BrokerNotAvailableError: Broker not available”
在生产者节点 ZKQuorum 字段中，我输入了笔记本电脑的 ip 并将端口设置为 9092，正如我在 npm 站点上的示例中看到的那样。
我确定主题是正确的。
我确定 zookeeper 正在运行，kafka 服务器也在运行。事实上，如果我同时尝试将 kafka 与笔记本电脑控制台一起使用，效果会很好。
我还尝试使用 telnet 访问 kafka 生产者端口：连接被接受。

我已经在 node-red 社区上发布了同样的问题，但目前没有成功。关于这个问题的任何提示？

更新：

更新。我试图在 node-red 中实现一个 python 函数来向 kafka 生产者发送一条简单的消息，并且我获得了更深层次的错误日志： /usr/local/lib/python2.7/dist-packages/kafka/client_async.py”，第 808 行我打开了文件，在第 808 行有一个带有此注释的函数：

有用吗？

【问题讨论】：

您从哪台机器上尝试 telnet？有防火墙吗？
我使用 telnet 从树莓派到我的 macbook，在那里设置了 kafka 服务器。 OS X 防火墙已关闭。

标签： apache-kafka apache-zookeeper node-red

【解决方案1】：

您必须将 kafka 服务器属性上的接受侦听器字段配置为笔记本电脑的 IP 地址。尝试将 zookeeper 连接到实际 ip，而不是 localhost。

在 etc/kafka/server.properties 中试试这个属性：listeners=PLAINTEXT://<your ip here>:<kafka port here>。您必须重新启动 kafka 才能生效

【讨论】：

当然。 num.partitions=1 num.recovery.threads.per.data.dir=1 log.segment.bytes=1073741824 ######################## #### Zookeeper ############################ zookeeper.connect=localhost:2181 zookeeper.connection.timeout.ms=6000现在我刚刚尝试使用端口 2181 但失败了，因为服务器没有响应（出现中心错误红色框弹出窗口）。图形节点下方的字符串表示它已连接。抱歉，我不知道如何在 cmets 部分格式化。
没问题。尝试将 zookeeper 连接到实际 ip，而不是 localhost。
完成。没有改变。经纪人不可用。如果有重要性，我已经直接用 brew 安装了 kafka 和 zookeeper。 Kafka 服务器开始于：kafka-server-start /usr/local/etc/kafka/server.properties Kafka 消费者开始于：kafka-console-consumer --zookeeper localhost:2181 --topic test2 --from-beginning Kafka 生产者开始使用：kafka-console-producer --broker-list localho:9092 --topic test2
在 etc/kafka/server.properties 中试试这个属性：listeners=PLAINTEXT://<your ip here>:<kafka port here>。您必须重新启动 kafka 才能生效
你用来启动控制台生产者的命令是什么？