Class KafkaJSAdminConnector

Description

KafkaJS admin connector

Features:

  • admin connector manager for KafkaJS

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, Admin>

Description

Private connections storage

Private #current

#current: Admin

Description

Private link to selected (used) connection

Private #private

#private: any

Protected config

config: IConfig

Protected Readonly namespace

namespace: "KafkaJSAdmin" = 'KafkaJSAdmin'

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

  • connection(name?): Admin

  • Parameters

    • Optional name: string

    Returns Admin

create

  • create(config): Promise<Admin>

  • Parameters

    Returns Promise<Admin>

get

  • get(name?): Admin

  • Parameters

    • Optional name: string

    Returns Admin

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