From e8777ca93e963b0940f3b529db06ebf4944745c2 Mon Sep 17 00:00:00 2001 From: Debarghya Roy Date: Wed, 28 Apr 2021 12:34:07 +0530 Subject: [PATCH] protocol.js-OOM-fix --- lib/protocol/protocol.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/protocol/protocol.js b/lib/protocol/protocol.js index c86cb7e9..427a0b3e 100644 --- a/lib/protocol/protocol.js +++ b/lib/protocol/protocol.js @@ -262,7 +262,7 @@ function _decodeFetchResponse (resp, cb, maxTickMessages, version) { const topic = vars.topic; const partition = vars.partition; - if (errorCode !== 0) { + if (errorCode && errorCode !== 0) { return events.push((next) => { const err = new Error(ERROR_CODE[errorCode]); err.topic = topic;