无法通过 node-red 访问 kafka 生产者
Can't reach kafka producer with node-red
我已经在 raspberry pi 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 行有一个带有此注释的函数：
有帮助吗？
您必须将 kafka 服务器属性中的接受侦听器字段配置为笔记本电脑的 IP 地址。尝试将 zookeeper 连接到实际 ip，而不是 localhost。
在 etc/kafka/server 中试试这个 属性。属性：listeners=PLAINTEXT://<your ip here>:<kafka port here>。您必须重新启动 kafka 才能生效
我已经在 raspberry pi 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 行有一个带有此注释的函数：
有帮助吗？
您必须将 kafka 服务器属性中的接受侦听器字段配置为笔记本电脑的 IP 地址。尝试将 zookeeper 连接到实际 ip，而不是 localhost。
在 etc/kafka/server 中试试这个 属性。属性：listeners=PLAINTEXT://<your ip here>:<kafka port here>。您必须重新启动 kafka 才能生效