kafkajs - npm Package Compare versions

Comparing version 1.11.0-beta.1 to 1.11.0-beta.2

package.json

 {
   "name": "kafkajs",
-  "version": "1.11.0-beta.1",
+  "version": "1.11.0-beta.2",
   "description": "A modern Apache Kafka client for node.js",
@@ -81,5 +81,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "263ae478bc9bb91b904c3144aa16003dc0720cdd",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.10.0...263ae478bc9bb91b904c3144aa16003dc0720cdd"
+    "sha": "dc0a942e4ce38bf37dfb95c369c6fdee4b91c08e",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.10.0...dc0a942e4ce38bf37dfb95c369c6fdee4b91c08e"
   }
 }

src/cluster/connectionBuilder.js

 const Connection = require('../network/connection')
+const { KafkaJSNonRetriableError } = require('../errors')
 
+const validateBrokers = brokers => {
+  if (!brokers || brokers.length === 0) {
+    throw new KafkaJSNonRetriableError(`Failed to connect: expected brokers array and got nothing`)
+  }
+}
+
 module.exports = ({
@@ -17,2 +24,4 @@ socketFactory,
 }) => {
+  validateBrokers(brokers)
+
   const size = brokers.length
@@ -19,0 +28,0 @@ let index = 0

No alert changes

Improved metrics

Total package byte prevSize

471178

increased by0.06%

Lines of code

14002

increased by0.05%

No dependency changes