File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -142,9 +142,9 @@ export interface ConsumerStream extends Readable {
142142 close ( cb ?: ( ) => void ) : void ;
143143}
144144
145- type KafkaClientEvents = 'disconnected' | 'ready' | 'connection.failure' | 'event.error' | 'event.stats' | 'event.log' | 'event.event' | 'event.throttle' ;
146- type KafkaConsumerEvents = 'data' | 'partition.eof' | 'rebalance' | 'rebalance.error' | 'subscribed' | 'unsubscribed' | 'unsubscribe' | 'offset.commit' | KafkaClientEvents ;
147- type KafkaProducerEvents = 'delivery-report' | KafkaClientEvents ;
145+ export type KafkaClientEvents = 'disconnected' | 'ready' | 'connection.failure' | 'event.error' | 'event.stats' | 'event.log' | 'event.event' | 'event.throttle' ;
146+ export type KafkaConsumerEvents = 'data' | 'partition.eof' | 'rebalance' | 'rebalance.error' | 'subscribed' | 'unsubscribed' | 'unsubscribe' | 'offset.commit' | KafkaClientEvents ;
147+ export type KafkaProducerEvents = 'delivery-report' | KafkaClientEvents ;
148148
149149type EventListenerMap = {
150150 // ### Client
You can’t perform that action at this time.
0 commit comments