Skip to main content
Version: Current

KafkaBroker

@rotorsoft/act-root

@rotorsoft/act-root / act-notify / KafkaBroker

Class: KafkaBroker

Defined in: libs/act-notify/src/kafka.ts:28

Refuses loudly until fan-out semantics are implemented.

Implements​

Constructors​

Constructor​

new KafkaBroker(options?): KafkaBroker

Defined in: libs/act-notify/src/kafka.ts:31

Parameters​

options?​

KafkaBrokerOptions = {}

Returns​

KafkaBroker

Properties​

topic​

readonly topic: string

Defined in: libs/act-notify/src/kafka.ts:29

Methods​

publish()​

publish(_message): void

Defined in: libs/act-notify/src/kafka.ts:35

Parameters​

_message​

BrokerMessage

Returns​

void

Implementation of​

Broker.publish

subscribe()​

subscribe(_handler): BrokerDisposer

Defined in: libs/act-notify/src/kafka.ts:39

Parameters​

_handler​

(message) => void

Returns​

BrokerDisposer

Implementation of​

Broker.subscribe