Merge pull request #3 from sandeepkumarcel/IO-104076

IO-104076 | fix max call stack error
celigo · Dec 3, 2024 · f68b973 · f68b973
2 parents 04a3167 + 4bb53ee
commit f68b973
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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