Class ConsumerPool

Hierarchy

ConsumerPool

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new ConsumerPool(kafka: Kafka, rootTopic: string, consumerConfig?: Omit<ConsumerConfig, "groupId" | "allowAutoTopicCreation">, topicAdministrator?: TopicAdministrator): ConsumerPool

- Defined in src/consumer_pool.ts:15
Parameters
- kafka: Kafka
- rootTopic: string
- Default value consumerConfig: Omit<ConsumerConfig, "groupId" | "allowAutoTopicCreation"> = {}
- Optional topicAdministrator: TopicAdministrator
Returns ConsumerPool

Properties

Private consumerConfig

consumerConfig: Omit<ConsumerConfig, "groupId" | "allowAutoTopicCreation">

Private consumers

consumers: Map<string, Consumer> = new Map()

Private kafka

kafka: Kafka

Private observersByTransaction

observersByTransaction: Map<string, Map<string, Array<ActionObserver<IAction>>>> = new Map()

Private rootTopic

rootTopic: string

Private topicAdministrator

topicAdministrator: TopicAdministrator

Methods

Private broadcastAction

broadcastAction(topic: string, action: IAction): void

- Defined in src/consumer_pool.ts:106
Parameters
- topic: string
- action: IAction
Returns void

disconnectConsumers

disconnectConsumers(): Promise<void>

- Defined in src/consumer_pool.ts:67
Returns Promise<void>

registerTopicObserver

registerTopicObserver(__namedParameters: { observer: ActionObserver<IAction<DefaultPayload>>; topic: string; transactionId: string }): void

- Defined in src/consumer_pool.ts:89
Parameters
- __namedParameters: { observer: ActionObserver<IAction<DefaultPayload>>; topic: string; transactionId: string }
  - observer: ActionObserver<IAction<DefaultPayload>>
  - topic: string
  - transactionId: string
Returns void

startTransaction

startTransaction(transactionId: string): void

- Defined in src/consumer_pool.ts:77
Parameters
- transactionId: string
Returns void

stopTransaction

stopTransaction(transactionId: string): void

- Defined in src/consumer_pool.ts:85
Parameters
- transactionId: string
Returns void

streamActionsFromTopic

streamActionsFromTopic(topic: string): Promise<void>

- Defined in src/consumer_pool.ts:26
Parameters
- topic: string
Returns Promise<void>

Generated using TypeDoc