kafkajs - npm Package Compare versions

Comparing version 1.12.0-beta.13 to 1.12.0-beta.14

package.json

 {
   "name": "kafkajs",
-  "version": "1.12.0-beta.13",
+  "version": "1.12.0-beta.14",
   "description": "A modern Apache Kafka client for node.js",
@@ -81,5 +81,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "67c71927e9c649ff00a88eda8c752849b2eda864",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.11.0...67c71927e9c649ff00a88eda8c752849b2eda864"
+    "sha": "5910b1f3ce6cea7d73b0e266c48387fffb3ff355",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.11.0...5910b1f3ce6cea7d73b0e266c48387fffb3ff355"
   }
 }

src/errors.js

@@ -6,3 +6,3 @@ class KafkaJSError extends Error {
     this.message = e.message || e
-    this.name = this.constructor.name
+    this.name = 'KafkaJSError'
     this.retriable = retriable
@@ -16,2 +16,3 @@ this.helpUrl = e.helpUrl
     super(e, { retriable: false })
+    this.name = 'KafkaJSNonRetriableError'
   }
@@ -25,2 +26,3 @@ }
     this.code = e.code
+    this.name = 'KafkaJSProtocolError'
   }
@@ -34,2 +36,3 @@ }
     this.partition = partition
+    this.name = 'KafkaJSOffsetOutOfRange'
   }
@@ -45,2 +48,3 @@ }
     this.retryTime = retryTime
+    this.name = 'KafkaJSNumberOfRetriesExceeded'
   }
@@ -54,2 +58,3 @@ }
     this.code = code
+    this.name = 'KafkaJSConnectionError'
   }
@@ -66,6 +71,12 @@ }
     this.pendingDuration = pendingDuration
+    this.name = 'KafkaJSRequestTimeoutError'
   }
 }
 
-class KafkaJSMetadataNotLoaded extends KafkaJSError {}
+class KafkaJSMetadataNotLoaded extends KafkaJSError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSMetadataNotLoaded'
+  }
+}
 class KafkaJSTopicMetadataNotLoaded extends KafkaJSMetadataNotLoaded {
@@ -75,2 +86,3 @@ constructor(e, { topic } = {}) {
     this.topic = topic
+    this.name = 'KafkaJSTopicMetadataNotLoaded'
   }
@@ -83,2 +95,3 @@ }
     this.unknownPartitions = unknownPartitions
+    this.name = 'KafkaJSStaleTopicMetadataAssignment'
   }
@@ -92,14 +105,62 @@ }
     this.apiName = apiName
+    this.name = 'KafkaJSServerDoesNotSupportApiKey'
   }
 }
 
-class KafkaJSBrokerNotFound extends KafkaJSError {}
-class KafkaJSPartialMessageError extends KafkaJSNonRetriableError {}
-class KafkaJSSASLAuthenticationError extends KafkaJSNonRetriableError {}
-class KafkaJSGroupCoordinatorNotFound extends KafkaJSNonRetriableError {}
-class KafkaJSNotImplemented extends KafkaJSNonRetriableError {}
-class KafkaJSTimeout extends KafkaJSNonRetriableError {}
-class KafkaJSLockTimeout extends KafkaJSTimeout {}
-class KafkaJSUnsupportedMagicByteInMessageSet extends KafkaJSNonRetriableError {}
+class KafkaJSBrokerNotFound extends KafkaJSError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSBrokerNotFound'
+  }
+}
 
+class KafkaJSPartialMessageError extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSPartialMessageError'
+  }
+}
+
+class KafkaJSSASLAuthenticationError extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSSASLAuthenticationError'
+  }
+}
+
+class KafkaJSGroupCoordinatorNotFound extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSGroupCoordinatorNotFound'
+  }
+}
+
+class KafkaJSNotImplemented extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSNotImplemented'
+  }
+}
+
+class KafkaJSTimeout extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSTimeout'
+  }
+}
+
+class KafkaJSLockTimeout extends KafkaJSTimeout {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSLockTimeout'
+  }
+}
+
+class KafkaJSUnsupportedMagicByteInMessageSet extends KafkaJSNonRetriableError {
+  constructor() {
+    super(...arguments)
+    this.name = 'KafkaJSUnsupportedMagicByteInMessageSet'
+  }
+}
+
 module.exports = {
@@ -106,0 +167,0 @@ KafkaJSError,

No alert changes

Improved metrics

Total package byte prevSize

482367

increased by0.26%

Lines of code

14252

increased by0.38%

No dependency changes