Kafkajs频繁输出错误日志问题求助
Kafkajs频繁输出错误日志问题求助
大家好,我在Node.js项目里用的是Kafkajs 2.2.4版本,从项目启动第一天开始,就被它的错误日志搞得头大——差不多每周有两天,会突然冒出几百条错误日志。给大家贴几个典型的日志片段:
Connection error: Client network socket disconnected before secure TLS connection was established","broker"
Connection.logError (/app/node_modules/kafkajs/src/network/connection.js:111:7)","extractedFields":{"message":"at Connection.logError (/app/node_modules/kafkajs/src/network/connection.js:111:7)"}},
"logger":"kafkajs","message":"[Runner] The group is rebalancing, re-joining","groupId":"merchant-portal-group-mp-prod","memberId":"kafkajs-ccd39e17-085f-43de-a2d3-fc9ae1bf8d4a","error":"This is not the correct coordinator for this group"}}}]}"
偶尔还会出现服务崩溃,或者消息堆积好几个小时完全不消费的情况,但绝大多数时候(99%)服务运行都是正常的。最让我烦躁的是,这些错误日志有时候会连续刷好几个小时,完全停不下来。
有没有朋友遇到过类似的情况?我就是想搞清楚,是不是我在配置或者使用Kafkajs的时候哪里做错了?
备注:内容来源于stack exchange,提问作者Missak Boyajian
相关产品推荐
相关产品推荐

