0

我正在生产中的节点应用程序中使用 bluemix 消息中心服务。现在我们遇到了一个问题，即消息中心服务每天都出现故障，然后需要重新启动应用程序。这不能这样做。我们收到以下日志

2016-10-16T17:41:42.66+0100 [App/0] OUT Unable to consume topic: Error: Request returned
status code 404 but it was not in the accepted list. The REST API responded with the 
following message: Consumer instance not found.
2016-10-16T17:41:46.66+0100 [App/0] OUT got error: { [Error: Request returned status code 
404 but it was not in the accepted list. The REST API responded with the following message:
Consumer instance not found.] statusCode: 404, errorCode: 40403 }

有什么办法可以解决这个问题。这里失败了

 run: function(callback) {         
                    var that = this;
                    consumerInstance.get(topic)
                        .then(function(data) {
                            that.consume(data);
                            return callback();
                        })
                        .fail(function(error) {
                            console.log("got error: ", error);
                            return callback(error);
                        })
                }

这是我们用作参考的代码

https://github.com/ibm-cds-labs/Spark-Twitter-Watson-Dashboard/blob/master/server/messageHubBridge.js?s_tact=C43301PW

有关如何解决此问题的任何想法。谢谢，哈里什。

4

2 回答 2

2

您好，MessageHub 的 REST 端点每 24 小时回收一次。客户端应该通过创建一个新的消费者实例来处理这个问题。

HTH，江户

于 2016-10-20T10:48:24.327 回答
0

根据Message Hub 文档，REST 服务每天都会重新启动。REST API 重新启动后，您必须重新创建 Kafka 使用者实例。

谢谢，

西蒙。

于 2016-10-20T10:50:52.587 回答