Merge pull request #938 from bpinhosilva/master

Add UNKNOWN_TOPIC_OR_PARTITION check for addMultipleTargetTopics
tulios · Nov 4, 2020 · 3bd245d · 3bd245d
2 parents 668b85e + 643f6bc
commit 3bd245d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/cluster/index.js b/src/cluster/index.js
@@ -190,7 +190,7 @@ module.exports = class Cluster {
         try {
           await this.refreshMetadata()
         } catch (e) {
-          if (e.type === 'INVALID_TOPIC_EXCEPTION') {
+          if (e.type === 'INVALID_TOPIC_EXCEPTION' || e.type === 'UNKNOWN_TOPIC_OR_PARTITION') {
             this.targetTopics = previousTopics
           }