cap-nodejs

CAP Node.js API

---

CAP Node.js API / cap-transport-kafka/src / KafkaPublisher

Class: KafkaPublisher

Defined in: cap-transport-kafka/src/kafka-publisher.ts:27

Implements

• PublisherPort

Constructors

Constructor

new KafkaPublisher(options?): KafkaPublisher

Defined in: cap-transport-kafka/src/kafka-publisher.ts:34

Parameters

options?

KafkaOptions = {}

Returns

KafkaPublisher

Methods

close()

close(): Promise<void>

Defined in: cap-transport-kafka/src/kafka-publisher.ts:89

Returns

Promise<void>

---

emit()

emit(topic, payload, headers?, metadata?): Promise<void>

Defined in: cap-transport-kafka/src/kafka-publisher.ts:62

Parameters

topic

string

payload

unknown

headers?

CapHeaders

metadata?

PublishMetadata

Returns

Promise<void>

Implementation of

PublisherPort.emit

---

initialize()

initialize(_options?): Promise<void>

Defined in: cap-transport-kafka/src/kafka-publisher.ts:40

Parameters

_options?

InitOptions

Returns

Promise<void>

Implementation of

PublisherPort.initialize

This site is open source. Improve this page.