问题描述
在节点服务器中启动应用程序一定时间后,将 kafka 与节点集成时出现以下问题。
kafka 服务器没有任何日志,并且已经启动并运行。
/app/node_modules/async/dist/async.js:5329
return callback.apply(null,arguments);
^
nestedError: refreshbrokerMetadata Failed
at /app/node_modules/kafka-node/lib/kafkaClient.js:378:35
at /app/node_modules/async/dist/async.js:473:16
at next (/app/node_modules/async/dist/async.js:5329:29)
at /app/node_modules/async/dist/async.js:969:16
at KafkaClient.getAvailablebroker (/app/node_modules/kafka-node/lib/kafkaClient.js:330:12)
at /app/node_modules/kafka-node/lib/kafkaClient.js:373:23
at nextTask (/app/node_modules/async/dist/async.js:5324:14)
at Object.waterfall (/app/node_modules/async/dist/async.js:5334:5)
at KafkaClient.refreshbrokerMetadata (/app/node_modules/kafka-node/lib/kafkaClient.js:372:9)
at Immediate._onImmediate (/app/node_modules/kafka-node/lib/kafkaClient.js:782:20)
Caused By: Error: Unable to find available brokers to try
at KafkaClient.getAvailablebroker (/app/node_modules/kafka-node/lib/kafkaClient.js:330:21)
at /app/node_modules/kafka-node/lib/kafkaClient.js:373:23
at nextTask (/app/node_modules/async/dist/async.js:5324:14)
at Object.waterfall (/app/node_modules/async/dist/async.js:5334:5)
at KafkaClient.refreshbrokerMetadata (/app/node_modules/kafka-node/lib/kafkaClient.js:372:9)
at Immediate._onImmediate (/app/node_modules/kafka-node/lib/kafkaClient.js:782:20)
at processImmediate (internal/timers.js:461:21)
error Command Failed with exit code 1.
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)