微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

如何解决节点中的refreshbrokermetadata失败问题?

如何解决如何解决节点中的refreshbrokermetadata失败问题?

在节点服务器中启动应用程序一定时间后,将 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 举报,一经查实,本站将立刻删除。