kafkajs - npm Package Compare versions

Comparing version 1.15.0-beta.18 to 1.15.0-beta.19

package.json

 {
   "name": "kafkajs",
-  "version": "1.15.0-beta.18",
+  "version": "1.15.0-beta.19",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "668b85e6ae5bfdc91618bb8f2baf517dab354dc5",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...668b85e6ae5bfdc91618bb8f2baf517dab354dc5"
+    "sha": "3bd245d31f10acf83c91cba00e8cbb983947add5",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...3bd245d31f10acf83c91cba00e8cbb983947add5"
   }
 }

src/cluster/index.js

@@ -193,3 +193,3 @@ const BrokerPool = require('./brokerPool')
         } catch (e) {
-          if (e.type === 'INVALID_TOPIC_EXCEPTION') {
+          if (e.type === 'INVALID_TOPIC_EXCEPTION' || e.type === 'UNKNOWN_TOPIC_OR_PARTITION') {
             this.targetTopics = previousTopics
@@ -196,0 +196,0 @@ }

No alert changes

Improved metrics

Total package byte prevSize

670845

0.01%

No dependency changes