Revert topic when metadata fetching failes due to authorization.

stilyng94 · Jun 3, 2022 · ec78a0e · ec78a0e
1 parent a733eaa
commit ec78a0e
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/cluster/index.js b/src/cluster/index.js
@@ -229,7 +229,11 @@ module.exports = class Cluster {
         try {
           await this.refreshMetadata()
         } catch (e) {
-          if (e.type === 'INVALID_TOPIC_EXCEPTION' || e.type === 'UNKNOWN_TOPIC_OR_PARTITION') {
+          if (
+            e.type === 'INVALID_TOPIC_EXCEPTION' ||
+            e.type === 'UNKNOWN_TOPIC_OR_PARTITION' ||
+            e.type === 'TOPIC_AUTHORIZATION_FAILED'
+          ) {
             this.targetTopics = previousTopics
           }