0

我使用 node.js 创建了一个主题,并使用原型 MessageHub.prototype.topics.create(topic) 映射到 Message Hub。我想将现有的 Message Hub 主题添加到 node.js 并从中使用数据。这有什么功能吗?

4

2 回答 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 回答