diff --git a/types/index.d.ts b/types/index.d.ts index 24058b6d..37dde6f4 100644 --- a/types/index.d.ts +++ b/types/index.d.ts @@ -26,6 +26,8 @@ export class KafkaClient extends EventEmitter { export class Producer extends EventEmitter { constructor (client: KafkaClient, options?: ProducerOptions, customPartitioner?: CustomPartitioner); + static PARTITIONER_TYPES: PartitionerTypes; + on (eventName: 'ready', cb: () => any): this; on (eventName: 'error', cb: (error: any) => any): this; @@ -348,3 +350,11 @@ export interface MetadataResponse extends Array