kafkajs - npm Package Compare versions

Comparing version 1.15.0-beta.0 to 1.15.0-beta.1

package.json

 {
   "name": "kafkajs",
-  "version": "1.15.0-beta.0",
+  "version": "1.15.0-beta.1",
   "description": "A modern Apache Kafka client for node.js",
@@ -83,5 +83,5 @@ "author": "Tulio Ornelas <[e-mail]>",
   "kafkajs": {
-    "sha": "7acda2785ac0ead9b26bd04c471ea4520ac0e150",
-    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...7acda2785ac0ead9b26bd04c471ea4520ac0e150"
+    "sha": "930bd2458ebe695658939e129d5a0fa48bdcfc02",
+    "compare": "https://github.com/tulios/kafkajs/compare/v1.14.0...930bd2458ebe695658939e129d5a0fa48bdcfc02"
   }
 }

types/index.d.ts

@@ -6,4 +6,4 @@ /// <reference types="node" />
 
-type Without<T, U> = { [P in Exclude<keyof T, keyof U>]?: never };
-type XOR<T, U> = (T | U) extends object ? (Without<T, U> & U) | (Without<U, T> & T) : T | U;
+type Without<T, U> = { [P in Exclude<keyof T, keyof U>]?: never }
+type XOR<T, U> = T | U extends object ? (Without<T, U> & U) | (Without<U, T> & T) : T | U
 
@@ -18,3 +18,3 @@ export class Kafka {
 
-export type BrokersFunction = () => string[] | Promise<string[]>;
+export type BrokersFunction = () => string[] | Promise<string[]>
 
@@ -46,4 +46,4 @@ export interface KafkaConfig {
 
-export interface OauthbearerProviderResponse { 
-  value: string 
+export interface OauthbearerProviderResponse {
+  value: string
 }
@@ -149,6 +149,8 @@
   fetchTopicsOffset(
-    topics: Array<{
-      topic: string
-      partitions: Array<{ partition: number }>
-    } & XOR<{ fromBeginning: boolean }, { fromTimestamp: number }>>
+    topics: Array<
+      {
+        topic: string
+        partitions: Array<{ partition: number }>
+      } & XOR<{ fromBeginning: boolean }, { fromTimestamp: number }>
+    >
   ): Promise<{ topic: string; partitions: Array<{ partition: number; offset: string }> }>
@@ -159,3 +161,3 @@ }
 
-export type GroupMember = { memberId: string, memberMetadata: Buffer }
+export type GroupMember = { memberId: string; memberMetadata: Buffer }
 
@@ -169,6 +171,3 @@ export type GroupMemberAssignment = { memberId: string; memberAssignment: Buffer }
   version: number
-  assign(group: {
-    members: GroupMember[]
-    topics: string[]
-  }): Promise<GroupMemberAssignment[]>
+  assign(group: { members: GroupMember[]; topics: string[] }): Promise<GroupMemberAssignment[]>
   protocol(subscription: { topics: string[] }): GroupState
@@ -333,9 +332,9 @@ }
   }): Promise<Array<SeekEntry & { metadata: string | null }>>
-  fetchTopicOffsets(
-    topic: string
-  ): Promise<Array<SeekEntry & { high: string; low: string }>>
-  fetchTopicOffsetsByTimestamp(
-    topic: string, timestamp?: number
-  ): Promise<Array<SeekEntry>>
-  describeCluster(): Promise<{ brokers: Array<{ nodeId: number; host: string; port: number }>; controller: number | null, clusterId: string }>
+  fetchTopicOffsets(topic: string): Promise<Array<SeekEntry & { high: string; low: string }>>
+  fetchTopicOffsetsByTimestamp(topic: string, timestamp?: number): Promise<Array<SeekEntry>>
+  describeCluster(): Promise<{
+    brokers: Array<{ nodeId: number; host: string; port: number }>
+    controller: number | null
+    clusterId: string
+  }>
   setOffsets(options: { groupId: string; topic: string; partitions: SeekEntry[] }): Promise<void>
@@ -347,5 +346,5 @@ resetOffsets(options: { groupId: string; topic: string; earliest: boolean }): Promise<void>
   }): Promise<DescribeConfigResponse>
-  alterConfigs(configs: { validateOnly: boolean; resources: IResourceConfig[] }): Promise<any>,
-  listGroups(): Promise<{ groups: GroupOverview[] }>,
-  deleteGroups(groupIds: string[]): Promise<DeleteGroupsResult[]>,
+  alterConfigs(configs: { validateOnly: boolean; resources: IResourceConfig[] }): Promise<any>
+  listGroups(): Promise<{ groups: GroupOverview[] }>
+  deleteGroups(groupIds: string[]): Promise<DeleteGroupsResult[]>
   describeGroups(groupIds: string[]): Promise<GroupDescriptions>
@@ -422,3 +421,3 @@ logger(): Logger
   ): Promise<{
-    brokers: Array<{ nodeId: number; host: string; port: number, rack?: string }>
+    brokers: Array<{ nodeId: number; host: string; port: number; rack?: string }>
     topicMetadata: Array<{
@@ -438,9 +437,12 @@ topicErrorCode: number
   fetch(request: {
-    replicaId?: number,
-    isolationLevel?: number,
-    maxWaitTime?: number,
-    minBytes?: number,
-    maxBytes?: number,
-    topics: Array<{ topic: string, partitions: Array<{ partition: number; fetchOffset: string; maxBytes: number }> }>,
-    rackId?: string,
+    replicaId?: number
+    isolationLevel?: number
+    maxWaitTime?: number
+    minBytes?: number
+    maxBytes?: number
+    topics: Array<{
+      topic: string
+      partitions: Array<{ partition: number; fetchOffset: string; maxBytes: number }>
+    }>
+    rackId?: string
   }): Promise<any>
@@ -588,3 +590,3 @@ }
 export type GroupOverview = {
-  groupId: string,
+  groupId: string
   protocolType: string
@@ -594,3 +596,3 @@ }
 export type DeleteGroupsResult = {
-  groupId: string,
+  groupId: string
   errorCode?: number
@@ -665,2 +667,3 @@ }
   groupId: string
+  restart: boolean
 }>
@@ -667,0 +670,0 @@

No alert changes

Improved metrics

Total package byte prevSize

578945

0

Lines of code

17035

0.02%

No dependency changes