kafkajs - npm Package Compare versions

Comparing version 1.13.0-beta.1 to 1.13.0-beta.2

package.json

 {
   "name": "kafkajs",
-  "version": "1.13.0-beta.1",
+  "version": "1.13.0-beta.2",
   "description": "A modern Apache Kafka client for node.js",
@@ -81,5 +81,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "987db4bc7a879fed3e75bc55f7af4baa7161c7f4",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...987db4bc7a879fed3e75bc55f7af4baa7161c7f4"
+    "sha": "43e3028c9f8e071f23343cba2478fc4454b79d1e",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.12.0...43e3028c9f8e071f23343cba2478fc4454b79d1e"
   }
 }

types/index.d.ts

@@ -675,1 +675,122 @@ /// <reference types="node" />
 }
+
+export class KafkaJSError extends Error {
+  constructor(e: Error | string, metadata?: KafkaJSErrorMetadata)
+}
+
+export class KafkaJSNonRetriableError extends KafkaJSError {
+  constructor(e: Error | string)
+}
+
+export class KafkaJSProtocolError extends KafkaJSError {
+  constructor(e: Error | string)
+}
+
+export class KafkaJSOffsetOutOfRange extends KafkaJSProtocolError {
+  constructor(e: Error | string, metadata?: KafkaJSOffsetOutOfRangeMetadata)
+}
+
+export class KafkaJSNumberOfRetriesExceeded extends KafkaJSNonRetriableError {
+  constructor(e: Error | string, metadata?: KafkaJSNumberOfRetriesExceededMetadata)
+}
+
+export class KafkaJSConnectionError extends KafkaJSError {
+  constructor(e: Error | string, metadata?: KafkaJSConnectionErrorMetadata)
+}
+
+export class KafkaJSRequestTimeoutError extends KafkaJSError {
+  constructor(e: Error | string, metadata?: KafkaJSRequestTimeoutErrorMetadata)
+}
+
+export class KafkaJSMetadataNotLoaded extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSTopicMetadataNotLoaded extends KafkaJSMetadataNotLoaded {
+  constructor(e: Error | string, metadata?: KafkaJSTopicMetadataNotLoadedMetadata)
+}
+
+export class KafkaJSStaleTopicMetadataAssignment extends KafkaJSError {
+  constructor(e: Error | string, metadata?: KafkaJSStaleTopicMetadataAssignmentMetadata)
+}
+
+export class KafkaJSServerDoesNotSupportApiKey extends KafkaJSNonRetriableError {
+  constructor(e: Error | string, metadata?: KafkaJSServerDoesNotSupportApiKeyMetadata)
+}
+
+export class KafkaJSBrokerNotFound extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSPartialMessageError extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSSASLAuthenticationError extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSGroupCoordinatorNotFound extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSNotImplemented extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSTimeout extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSLockTimeout extends KafkaJSError {
+  constructor()
+}
+
+export class KafkaJSUnsupportedMagicByteInMessageSet extends KafkaJSError {
+  constructor()
+}
+
+export interface KafkaJSErrorMetadata {
+  retriable?: boolean
+  topic?: string
+  partitionId?: number
+  metadata?: PartitionMetadata
+}
+
+export interface KafkaJSOffsetOutOfRangeMetadata {
+  topic: string
+  partition: number
+}
+
+export interface KafkaJSNumberOfRetriesExceededMetadata {
+  retryCount: number
+  retryTime: number
+}
+
+export interface KafkaJSConnectionErrorMetadata {
+  broker?: string
+  code?: string
+}
+
+export interface KafkaJSRequestTimeoutErrorMetadata {
+  broker: string
+  clientId: string
+  correlationId: number
+  createdAt: number
+  sentAt: number
+  pendingDuration: number
+}
+
+export interface KafkaJSTopicMetadataNotLoadedMetadata {
+  topic: string
+}
+
+export interface KafkaJSStaleTopicMetadataAssignmentMetadata {
+  topic: string
+  unknownPartitions: PartitionMetadata[]
+}
+
+export interface KafkaJSServerDoesNotSupportApiKeyMetadata {
+  apiKey: number
+  apiName: string
+}

No alert changes

Improved metrics

Total package byte prevSize

492109

increased by0.62%

Lines of code

14511

increased by0.65%

No dependency changes