我有一个使用 node-rdkafka 1.0.3 的 Bluemix Node.js (6.1.0) 应用程序。它似乎工作正常,但有大量错误事件,例如Error: Local: Broker Transport Failure
or Error: Local: Authentication failure
。我设置的生产者选项是:
var producer_opts = {
"metadata.broker.list":env.messagehub.brokers,
"security.protocol":"sasl_ssl",
"ssl.ca.location":env.messagehub.calocation,
"sasl.mechanisms":"PLAIN",
"sasl.username":env.messagehub.user,
"sasl.password":env.messagehub.password,
"api.version.request":true,
"socket.timeout.ms": 10000,
"dr_msg_cb":true
};
消费者有类似的设置加上group.id
标签。
我想知道我是否应该担心这些错误以及是否有办法消除它们。谢谢!