kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.38 to 1.13.0-beta.39

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.38",
+  "version": "1.13.0-beta.39",
   "description": "A modern Apache Kafka client for node.js",
@@ -66,3 +66,3 @@ "author": "Tulio Ornelas <[e-mail]>",
     "lint-staged": "^9.2.0",
-    "mockdate": "^2.0.3",
+    "mockdate": "^2.0.5",
     "prettier": "^1.18.2",
@@ -83,5 +83,5 @@ "semver": "^6.2.0",
   "kafkajs": {
-    "sha": "e2960b3e207c0052753f16cc6499f1e0ac4c4655",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...e2960b3e207c0052753f16cc6499f1e0ac4c4655"
+    "sha": "d86af3a229915f5acfaee96609dc8f54744787ea",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...d86af3a229915f5acfaee96609dc8f54744787ea"
   }
 }

src/network/requestQueue/index.js

@@ -125,2 +125,9 @@ const SocketRequest = require('./socketRequest')
 
+    this.sendSocketRequest(socketRequest)
+  }
+
+  /**
+   * @param {SocketRequest} socketRequest
+   */
+  sendSocketRequest(socketRequest) {
     socketRequest.send()
@@ -132,6 +139,6 @@
         broker: this.broker,
-        correlationId,
+        correlationId: socketRequest.correlationId,
       })
 
-      this.inflight.delete(correlationId)
+      this.inflight.delete(socketRequest.correlationId)
       socketRequest.completed({ size: 0, payload: null })
@@ -152,3 +159,3 @@ }
       const pendingRequest = this.pending.pop()
-      pendingRequest.send()
+      this.sendSocketRequest(pendingRequest)
 
@@ -155,0 +162,0 @@ this.logger.debug(`Consumed pending request`, {

No alert changes

Improved metrics

Total package byte prevSize

516541

0.04%

Lines of code

15292

0.04%

No dependency changes