diff --git a/types/kafkajs.d.ts b/types/kafkajs.d.ts index 58d03a5b..8995def4 100644 --- a/types/kafkajs.d.ts +++ b/types/kafkajs.d.ts @@ -191,6 +191,9 @@ export type Producer = Client & { sendBatch(batch: ProducerBatch): Promise flush(args?: { timeout?: number }): Promise + on(name: 'ready', cb: () => void): void; + on(name: 'event.error', cb: (err: unknown) => void): void; + // Transactional producer-only methods. transaction(): Promise commit(): Promise