我使用node.js创建了一个主题,并使用prototype MessageHub.prototype.topics.create( topic )映射到Message。我希望向node.js添加一个现有的消息中心主题,并使用其中的数据。这有什么功能吗?
发布于 2016-12-08 01:27:07
@rajeswari我猜您正在使用使用的node.js模块。
可以随意查看一下使用本地Node.js客户端为Kafka的示例,
https://github.com/ibm-messaging/message-hub-samples/tree/master/kafka-nodejs-console-sample
发布于 2016-12-07 15:53:12
@rajeswari,topics.create(topicName)调用只是请求,主题是在MessageHub中创建的,当它的承诺返回时,该请求的json输出响应是可用的。
如果您想从现有主题中检索消息,可以跳过这一步,直接通过MessageHub.prototype.consume创建MessageHub.prototype.consume,然后在返回的ConsumerInstance上调用MessageHub.ConsumerInstance.prototype.get(topicName)。
https://stackoverflow.com/questions/41019010
复制相似问题