Class RDKafkaConsumerStreamConnector

Description

RDKafka consumer stream connector

Features:

  • Consumer stream connector manager for node-rdkafka

Example

Hierarchy

Constructors

constructor

Properties

#connections #current #private config namespace

Accessors

connections current

Methods

connect connection create get initialize use

Constructors

constructor

Properties

Private #connections

#connections: Map<string, IRDKafkaConsumerStreamConnection>

Description

Private connections storage

Private #current

#current: IRDKafkaConsumerStreamConnection

Description

Private link to selected (used) connection

Private #private

#private: any

Protected config

config: IConfig

Protected Readonly namespace

namespace: "RDKafkaConsumerStream" = 'RDKafkaConsumerStream'

Description

Namespace path for fetching configuration

Accessors

connections

  • get connections(): Map<string, T>

  • Returns Map<string, T>

current

  • get current(): T

  • Returns T

Methods

Protected connect

connection

create

get

Protected initialize

  • initialize(): Promise<void>

  • Returns Promise<void>

use

  • use(name): void

  • Parameters

    • name: string

    Returns void

Settings

Member Visibility

Theme

On This Page

constructor#connections#current#privateconfignamespaceconnectionscurrentconnectconnectioncreategetinitializeuse