kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.17 to 1.13.0-beta.18

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.17",
+  "version": "1.13.0-beta.18",
   "description": "A modern Apache Kafka client for node.js",
@@ -82,5 +82,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "cfbb49d2133719683babe07c9e3d33068a3dae4a",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...cfbb49d2133719683babe07c9e3d33068a3dae4a"
+    "sha": "985d1db8c092471f6c849d6809137c87bc37c93e",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...985d1db8c092471f6c849d6809137c87bc37c93e"
   }
 }

src/admin/index.js

@@ -50,3 +50,3 @@ const createRetry = require('../retry')
   instrumentationEmitter: rootInstrumentationEmitter,
-  retry = { retries: 5 },
+  retry,
   cluster,
@@ -53,0 +53,0 @@ }) => {

src/consumer/index.js

@@ -29,2 +29,3 @@ const Long = require('long')
   groupId,
+  retry,
   logger: rootLogger,
@@ -39,3 +40,2 @@ partitionAssigners = [roundRobin],
   maxWaitTimeInMs = 5000,
-  retry = { retries: 10 },
   isolationLevel = ISOLATION_LEVEL.READ_COMMITTED,
@@ -42,0 +42,0 @@ instrumentationEmitter: rootInstrumentationEmitter,

src/index.js

@@ -119,3 +119,3 @@ const {
     maxWaitTimeInMs,
-    retry,
+    retry = { retries: 10 },
     allowAutoTopicCreation,
@@ -122,0 +122,0 @@ maxInFlightRequests,

No alert changes

Worsened metrics

Total package byte prevSize

513137

0

No dependency changes