Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ThrottledProducer

Hierarchy

  • ThrottledProducer

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Private intervalTimeout

intervalTimeout: Timeout

Private isConnected

isConnected: boolean = false

Private isFlushing

isFlushing: boolean = false

Protected kafka

kafka: Kafka

Private logger

logger: pino.Logger

Private producer

producer: Producer

Protected producerConfig

producerConfig: SagaProducerConfig

Private recordQueue

recordQueue: IQueuedRecord[] = []

recordsSent

recordsSent: number = 0

Methods

connect

  • connect(): Promise<void>

Private createProducer

  • createProducer(): void

disconnect

  • disconnect(): Promise<void>

Private flush

  • flush(retryRecords?: IQueuedRecord[], retryCounter?: number, retryBatchId?: undefined | string): Promise<void>

putAction

  • putAction<Action>(action: Action, messageConfig?: { useTransactionIdAsKey?: undefined | false | true }): Promise<void>

  • Type parameters

    Parameters

    • action: Action
    • Default value messageConfig: { useTransactionIdAsKey?: undefined | false | true } = {useTransactionIdAsKey: false}
      • Optional useTransactionIdAsKey?: undefined | false | true

        If using transactionId as a message key, messages in a transaction will be processed in order.

    Returns Promise<void>

Generated using TypeDoc