kafkajs - npm Package Compare versions

Comparing version 1.16.0-beta.23 to 1.16.0-beta.24

package.json

 {
   "name": "kafkajs",
-  "version": "1.16.0-beta.23",
+  "version": "1.16.0-beta.24",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "ca0454dc4dde5c635696a66ef97466dea905d410",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.15.0...ca0454dc4dde5c635696a66ef97466dea905d410"
+    "sha": "812e055037519414d5a4cff491d817c7633b157f",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.15.0...812e055037519414d5a4cff491d817c7633b157f"
   }
 }

src/consumer/offsetManager/index.js

@@ -146,11 +146,2 @@ const Long = require('../../utils/long')
 
-    if (!this.autoCommit) {
-      this.resolveOffset({
-        topic,
-        partition,
-        offset: defaultOffset,
-      })
-      return
-    }
-
     await coordinator.offsetCommit({
@@ -157,0 +148,0 @@ groupId,

No alert changes

Worsened metrics

Total package byte prevSize

691192

decreased by-0.02%

Lines of code

20363

decreased by-0.04%

No dependency changes