Class KafkaThresholdBreachedConsumer

Index

Constructors

Methods

connect disconnect start

Constructors

constructor

new KafkaThresholdBreachedConsumer(
    brokers: string[],
    clientId: string,
    groupId: string,
    topic: string,
    handler: ThresholdBreachedHandler,
    logger?: Logger,
): KafkaThresholdBreachedConsumer
Parameters
- brokers: string[]
- clientId: string
- groupId: string
- topic: string
- handler: ThresholdBreachedHandler
- Optionallogger: Logger
Returns KafkaThresholdBreachedConsumer
- Defined in src/presentation/messaging/KafkaThresholdBreachedConsumer.ts:11

Methods

connect

connect(): Promise<void>
Returns Promise<void>
- Defined in src/presentation/messaging/KafkaThresholdBreachedConsumer.ts:30

disconnect

disconnect(): Promise<void>
Returns Promise<void>
- Defined in src/presentation/messaging/KafkaThresholdBreachedConsumer.ts:55

start

start(): Promise<void>
Returns Promise<void>
- Defined in src/presentation/messaging/KafkaThresholdBreachedConsumer.ts:39