kafkajs - npm Package Compare versions

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

package.json

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

src/utils/concurrency.js

@@ -9,3 +9,3 @@ const { KafkaJSNonRetriableError } = require('../errors')
 const concurrency = ({ limit, onChange = NOOP } = {}) => {
-  if (typeof limit !== 'number' || limit < 1) {
+  if (isNaN(limit) || typeof limit !== 'number' || limit < 1) {
     throw new KafkaJSNonRetriableError(`"limit" cannot be less than 1`)
@@ -12,0 +12,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

516557

0

No dependency changes