1

我正在尝试使用 Kafka 输入节点 (node-red-contrib-kafka-node) 在 Bluemix 节点红色应用程序中使用消息。我有一个绑定到我的应用程序的消息集线器服务,并且我正在使用本地 Java 应用程序将消息写入主题。为了能够使用这些消息,Kafka 输入节点的 ZK Quorum 属性应该包含什么?

4

1 回答 1

2

由于 Message Hub 是一个安全的 Kafka 安装,并且我们不提供对 Zookeeper 的公共访问权限,因此 Kafka 模块无法与 Message Hub 一起使用。但是,我刚刚使用官方 Message Hub Node.js 客户端发布了一个与 Message Hub 一起使用的 Node RED 模块。

https://www.npmjs.com/package/node-red-contrib-messagehub-node

请试一试,请注意这是第一个版本,我只是尽快创建它,以便您继续前进。如果您还有其他问题,请告诉我。

于 2016-04-13T23:21:48.203 回答