kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.10 to 1.13.0-beta.11

package.json

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

src/consumer/runner.js

@@ -365,3 +365,5 @@ const Long = require('long')
     await Promise.all(enqueuedTasks.map(fn => fn()))
-    await lock
+    if (expectedNumberOfExecutions > 0) {
+      await lock
+    }
     await this.autoCommitOffsets()
@@ -368,0 +370,0 @@ await this.consumerGroup.heartbeat({ interval: this.heartbeatInterval })

No alert changes

Improved metrics

Total package byte prevSize

505883

0.01%

Lines of code

14956

0.01%

No dependency changes