kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.36 to 1.13.0-beta.37

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.36",
+  "version": "1.13.0-beta.37",
   "description": "A modern Apache Kafka client for node.js",
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "2df50c1363496690274127b4b4dd403b2bc0d1e3",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...2df50c1363496690274127b4b4dd403b2bc0d1e3"
+    "sha": "9ed0787bbe16df4402923f0ea898a2fca6200736",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...9ed0787bbe16df4402923f0ea898a2fca6200736"
   }
 }

src/protocol/decoder.js

@@ -136,5 +136,5 @@ const Long = require('long')
 
-    const array = []
+    const array = new Array(length)
     for (let i = 0; i < length; i++) {
-      array.push(reader(this))
+      array[i] = reader(this)
     }
@@ -152,5 +152,5 @@
 
-    const array = []
+    const array = new Array(length)
     for (let i = 0; i < length; i++) {
-      array.push(reader(this))
+      array[i] = reader(this)
     }
@@ -168,5 +168,5 @@
 
-    const array = []
+    const array = new Array(length)
     for (let i = 0; i < length; i++) {
-      array.push(await reader(this))
+      array[i] = await reader(this)
     }
@@ -173,0 +173,0 @@

src/protocol/recordBatch/v0/decoder.js

@@ -98,6 +98,6 @@ const Decoder = require('../../decoder')
   const decompressedRecordDecoder = new Decoder(decompressedRecordBuffer)
-  const records = []
+  const records = new Array(length)
 
   for (let i = 0; i < length; i++) {
-    records.push(decodeRecord(decompressedRecordDecoder, recordContext))
+    records[i] = decodeRecord(decompressedRecordDecoder, recordContext)
   }
@@ -104,0 +104,0 @@

No alert changes

Improved metrics

Total package byte prevSize

516359

0.01%

No dependency changes