无法通过node red联系到Kafka制作人
我已经在覆盆子pi 3上安装了node-red来从传感器收集数据，然后将它们存储在kafka中，但是现在我对kafka生产者节点有一些问题。我在笔记本电脑上安装了一个kafka服务器，它可以在控制台上正确工作：如果我在kafka生产者控制台上发送消息，我可以在消费者控制台上正确接收。不幸的是，当我试图在覆盆子上的node-red中注入kafka生产者的时间戳时，服务器没有响应。
- node red的调试页面显示：“BrokerNotAvailableError:Broker不可用”
- 在producer node ZKQuorum字段中，我输入了笔记本电脑的ip，并将端口设置为9092，正如我在npm站点上的示例中看到的那样
- 我相信这个话题是正确的
- 我确信zookeeper正在运行，Kafka服务器也在运行。事实上，如果我同时尝试将Kafka与笔记本电脑控制台结合使用，效果会很好
- 我还尝试通过telnet访问Kafka制作人端口：接受连接
我已经在node red社区上发布了相同的问题，但目前还没有成功。关于这个问题有什么提示吗？
更新：
这会有帮助吗？
共有1个答案
您必须将kafka服务器属性上的accepted listeners字段配置为笔记本电脑的IP地址。尝试将zookeeper连接更改为实际ip，而不是本地主机。
在etc/kafka/server.properties中尝试此属性：listeners=PLAINTEXT：//
-
在我们的docker-swarm中运行kafka connect，使用以下撰写文件： kafka connect节点成功启动，我可以设置任务并查看这些任务的状态······ 我是否在撰写文件或任务配置中缺少某些配置？
-
问题内容： 我在OS X 10.10.5 Yosemite上安装了带有Homebrew的MySQL和MySQL。我的Python 2.7在处带有符号链接。 在其中有一个符号链接： 错误 在Python Shell中： 所以我尝试了： 其次是： 然后（绝望的原因）： 但是在两种情况下仍然尝试导入。 然后我尝试 了： 现有答案 很多回答 这个 问题 的SO建议您手动进行明确的符号链接到同一个版本号库（
-
我在这里得到了一个完整的示例应用程序：https://github.com/MrMojoR/hibernateOnKotlin 这段代码基于这篇博客文章：https://kotlinexpertise.com/hibernate-with-kotlin-spring-boot/ 问题是，虽然懒惰提取在集成测试中工作得很好，但调试器中有一个异常：来自测试的异常 当我从控制器运行相同的代码时，没有异常
-
我有一个RestController正在工作，我想学习如何使用Spring Security性启用基本身份验证。 我创建了一个扩展WebSecurityConfigureAdapter的类，据我所知，它已经足够了。遗憾的是，我可以在不提供凭据的情况下调用资源。 这是我的代码： 配置适配器 Spring配置文件 网状物xml 还有我的pom文件 我正在使用Tomcat v6.0m服务器日志看起来不错
-
问题内容： 我最近安装了Elasticsearch，并且在开始的几天里一切正常，但是今天以某种方式停止了工作 当我启动该服务时，它声称很好… 但后来我明白了 查看elasticsearch日志： 看起来有关于Java VM的警告；那可能是问题吗？我还应该尝试/看看什么？ 问题答案： 1） 使用linux中的命令 检查端口9200的状态 。 就我而言，以下是启动时的结果。 对我不是服务，否则找到正在
-
这几天来，我无法在本地运行mac os ML的机器上连接到我的postgreSQL数据库。 我机器的nmap显示postgres在5432上运行，我可以通过pgadmin和psql进行本地连接。 收听地址设置为* 当我尝试连接JDBC时，我会遇到以下异常 组织。postgresql。util。PSQLException:连接被拒绝。检查主机名和端口是否正确，邮政局长是否接受TCP/IP连接。