From 4bb53ee62642b722ce219975c6fe3fe0cb2be896 Mon Sep 17 00:00:00 2001 From: sandeep kumar Date: Wed, 20 Nov 2024 16:18:54 +0530 Subject: [PATCH] fix max call stack error --- src/protocol/requests/fetch/v4/decodeMessages.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/protocol/requests/fetch/v4/decodeMessages.js b/src/protocol/requests/fetch/v4/decodeMessages.js index abae0f515..32abc4959 100644 --- a/src/protocol/requests/fetch/v4/decodeMessages.js +++ b/src/protocol/requests/fetch/v4/decodeMessages.js @@ -25,7 +25,9 @@ const decodeMessages = async decoder => { while (messagesDecoder.canReadBytes(RECORD_BATCH_OVERHEAD)) { try { const recordBatch = await RecordBatchDecoder(messagesDecoder) - records.push(...recordBatch.records) + for(let i = 0; i < recordBatch.records.length; i++) { + records.push(recordBatch.records[i]) + } } catch (e) { // The tail of the record batches can have incomplete records // due to how maxBytes works. See https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-FetchAPI