Include topic in error message

tulios · Jan 7, 2024 · 1ce4ce6 · 1ce4ce6
1 parent fad3e16
commit 1ce4ce6
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/src/errors.js b/src/errors.js
@@ -40,9 +40,10 @@ class KafkaJSOffsetOutOfRange extends KafkaJSProtocolError {
 
 class KafkaJSUnknownTopic extends KafkaJSProtocolError {
   constructor(e, { topic }) {
-    super(e, { retriable: false })
+    super(e)
     this.topic = topic
     this.name = 'KafkaJSUnknownTopic'
+    this.message = `${this.message} [${this.topic}]`
   }
 }
 
@@ -51,6 +52,7 @@ class KafkaJSTopicAuthorizationFailed extends KafkaJSProtocolError {
     super(e, { retriable: false })
     this.topic = topic
     this.name = 'KafkaJSTopicAuthorizationFailed'
+    this.message = `${this.message} [${this.topic})]`
   }
 }
 class KafkaJSMemberIdRequired extends KafkaJSProtocolError {

diff --git a/src/protocol/error.js b/src/protocol/error.js
@@ -24,7 +24,7 @@ const errorCodes = [
   {
     type: 'UNKNOWN_TOPIC_OR_PARTITION',
     code: 3,
-    retriable: true,
+    retriable: false,
     message: 'This server does not host this topic-partition',
   },
   {