我使用 node.js 创建了一个主题,并使用原型 MessageHub.prototype.topics.create(topic) 映射到 Message Hub。我想将现有的 Message Hub 主题添加到 node.js 并从中使用数据。这有什么功能吗?
问问题
82 次
2 回答
2
@rajeswari 我猜您正在使用使用 Message Hub REST API 的 node.js 模块。
随意查看使用 Kafka 的原生 Node.js 客户端的示例,
https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-nodejs-console-sample
于 2016-12-08T01:27:07.970 回答
2
@rajeswaritopics.create(topicName)
调用只是请求在 MessageHub 中创建主题,并且当它的 Promise 返回该请求的 json 输出响应时可用。
如果您想从现有主题中检索消息,您可以跳过该步骤并直接通过创建 ConsumerInstance MessageHub.prototype.consume
,然后调用MessageHub.ConsumerInstance.prototype.get(topicName)
返回的 ConsumerInstance。
于 2016-12-07T15:53:12.403 回答