Использование узлов Kafka в Bluemix и Node-Red

Я пытаюсь использовать сообщения в приложении Bluemix node-red, используя входной узел Kafka (node-red-contrib-kafka-node). У меня есть служба концентратора сообщений, привязанная к моему приложению, и я пишу сообщения в тему, используя локальное приложение Java. Что должно быть в свойстве ZK Quorum входного узла Kafka, чтобы можно было использовать эти сообщения?


ibm-cloud node-red kafka-consumer-api message-hub
person jd76    schedule 12.04.2016    source источник
comment
Вы используете старую версию клиента Kafka? Вам может потребоваться передать учетные данные в Message Hub из Node.js,   -  person ValerieLampkin    schedule 12.04.2016
comment
@ValerieLampkin В моем package.json есть node-red-contrib-kafka-node: 0.x   -  person jd76    schedule 12.04.2016

Ответы (1)


arrow_upward
2
arrow_downward

Поскольку Message Hub — это безопасная установка Kafka, и мы не предоставляем открытый доступ к Zookeeper, модуль Kafka просто не будет работать с Message Hub. Однако я только что выпустил модуль Node RED, который работает с Message Hub с использованием официального клиента Message Hub Node.js.

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

Пожалуйста, попробуйте, имейте в виду, что это первая версия, я просто создал ее как можно быстрее, чтобы вы могли двигаться дальше. Если у вас есть дополнительные вопросы, пожалуйста, дайте мне знать.

person Luis Elizondo    schedule 13.04.2016