cap-nodejs

CAP Node.js API

---

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

Class: KafkaSubscriber

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:33

Implements

• SubscriberPort

Constructors

Constructor

new KafkaSubscriber(options?): KafkaSubscriber

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:39

Parameters

options?

KafkaOptions = {}

Returns

KafkaSubscriber

Methods

close()

close(): Promise<void>

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:131

Returns

Promise<void>

Implementation of

SubscriberPort.close

---

consume()

consume(topic, group, handler): Promise<void>

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:49

Parameters

topic

string

group

string

handler

CapHandler

Returns

Promise<void>

Implementation of

SubscriberPort.consume

---

dispatchDelivery()

dispatchDelivery(group, delivery): Promise<void>

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:94

Adapter delivery boundary, exposed for controlled broker harnesses.

Parameters

group

string

delivery

EachMessagePayload

Returns

Promise<void>

---

initialize()

initialize(_options?): Promise<void>

Defined in: cap-transport-kafka/src/kafka-subscriber.ts:45

Parameters

_options?

InitOptions

Returns

Promise<void>

Implementation of

SubscriberPort.initialize

This site is open source. Improve this page.