Class KafkaConsumer

Kafka consumer client, abstraction on top of KafkaConsumer from node-rdkafka

Hierarchy

KafkaConsumer

Index

Methods

Methods

disconnect

disconnect(): Promise<unknown>

- Defined in consumer.ts:210
Returns Promise<unknown>

pause

pause(topicPartitions: Queue): any

- Defined in consumer.ts:222
Parameters
- topicPartitions: Queue
Returns any

resume

resume(topicPartitions: Queue): any

- Defined in consumer.ts:226
Parameters
- topicPartitions: Queue
Returns any

subscribe

subscribe(topicsParam: string[] | string | Queue[] | Queue, opts: SubscribeOptions, onMessage: OnMessageCallback, onError: OnErrorCallback): Promise<void>

- Defined in consumer.ts:131
Parameters
- topicsParam: string[] | string | Queue[] | Queue
- opts: SubscribeOptions
- onMessage: OnMessageCallback
- onError: OnErrorCallback
Returns Promise<void>

unsubscribe

unsubscribe(): undefined | KafkaConsumer

- Defined in consumer.ts:200
Returns undefined | KafkaConsumer

Static init

init(schemaClient: Schema, options: KafkaClientOptions): KafkaConsumer

- Defined in consumer.ts:53
Parameters
- schemaClient: Schema
- options: KafkaClientOptions
Returns KafkaConsumer

Generated using TypeDoc