Skip to content

Commit a5ed8cb

Browse files
tobydigzallen-paystack
authored andcommitted
add types for kafka Admin
1 parent fcc8aef commit a5ed8cb

File tree

1 file changed

+25
-0
lines changed

1 file changed

+25
-0
lines changed

types/index.d.ts

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,20 @@ export class ProducerStream extends Writable {
145145
_writev (chunks: Chunk[], cb: (error: any, data: any) => any): void;
146146
}
147147

148+
export class Admin extends EventEmitter {
149+
constructor (kafkaClient: KafkaClient);
150+
151+
listTopics (cb?: () => void): void;
152+
153+
listGroups (cb?: () => void): void;
154+
155+
describeGroups (consumerGroups: ConsumerGroup[], cb?: () => void): void;
156+
157+
createTopics (topics: string[], cb?: () => void): void;
158+
159+
describeConfigs(payload: { resources: Resource[], includeSynonyms?: boolean }, cb?: () => void): void;
160+
}
161+
148162
// # Interfaces
149163

150164
export interface Message {
@@ -348,3 +362,14 @@ export interface MetadataResponse extends Array<BrokerMetadataResponse|ClusterMe
348362
0: BrokerMetadataResponse;
349363
1: ClusterMetadataResponse;
350364
}
365+
366+
export enum RESOURCE_TYPES {
367+
topic = 'topic',
368+
broker = 'broker'
369+
}
370+
371+
export interface Resource {
372+
resourceType: RESOURCE_TYPES;
373+
resourceName: string,
374+
configNames: string,
375+
}

0 commit comments

Comments
 (0)