Class KafkaFactory

Hierarchy

KafkaFactory

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new KafkaFactory(kafkaHost: string, registryUrl: string): KafkaFactory

- Defined in index.ts:6
Parameters
- kafkaHost: string
- registryUrl: string
Returns KafkaFactory

Properties

Private kafkaHost

kafkaHost: string

Private registry

registry: any

Methods

buildConsumer

buildConsumer<Key, Subject>(descriptor: EventDescriptor<Key, Subject>, handler: function, err: function): object

- Defined in index.ts:34
Type parameters
- Key
- Subject
Parameters
- descriptor: EventDescriptor<Key, Subject>
- handler: function
  - - (message: KafkaMessage<Key, Subject>): void
    - Parameters
      - message: KafkaMessage<Key, Subject>
      Returns void
- err: function
  - - (err: any): void
    - Parameters
      - err: any
      Returns void
Returns object
- kafkaClient: KafkaClient
- kafkaConsumer: Consumer

buildConsumerForTopic

buildConsumerForTopic<Key, Subject>(topic: string, descriptor: EventDescriptor<Key, Subject>, handler: function, err: function): object

- Defined in index.ts:47
Type parameters
- Key
- Subject
Parameters
- topic: string
- descriptor: EventDescriptor<Key, Subject>
- handler: function
  - - (message: KafkaMessage<Key, Subject>): void
    - Parameters
      - message: KafkaMessage<Key, Subject>
      Returns void
- err: function
  - - (err: any): void
    - Parameters
      - err: any
      Returns void
Returns object
- kafkaClient: KafkaClient
- kafkaConsumer: Consumer

Private buildKafkaClient

buildKafkaClient(): KafkaClient

- Defined in index.ts:96
Returns KafkaClient

buildProducer

buildProducer<Key, Subject>(descriptor: EventDescriptor<Key, Subject>): (Anonymous function)

- Defined in index.ts:13
Type parameters
- Key
- Subject
Parameters
- descriptor: EventDescriptor<Key, Subject>
Returns (Anonymous function)

buildProducerForTopic

buildProducerForTopic<Key, Subject>(topic: string, descriptor: EventDescriptor<Key, Subject>): (Anonymous function)

- Defined in index.ts:19
Type parameters
- Key
- Subject
Parameters
- topic: string
- descriptor: EventDescriptor<Key, Subject>
Returns (Anonymous function)

primeSubjects

primeSubjects<Key, Subject>(descriptor: EventDescriptor<Key, Subject>): Promise<void>

- Defined in index.ts:79
Type parameters
- Key
- Subject
Parameters
- descriptor: EventDescriptor<Key, Subject>
Returns Promise<void>

Generated using TypeDoc