cap-nodejs

CAP Node.js API

---

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

Interface: KafkaConsumerClient

Defined in: cap-transport-kafka/src/kafka-types.ts:29

Methods

commitOffsets()

commitOffsets(offsets): Promise<void>

Defined in: cap-transport-kafka/src/kafka-types.ts:37

Parameters

offsets

object[]

Returns

Promise<void>

---

connect()

connect(): Promise<void>

Defined in: cap-transport-kafka/src/kafka-types.ts:30

Returns

Promise<void>

---

disconnect()

disconnect(): Promise<void>

Defined in: cap-transport-kafka/src/kafka-types.ts:31

Returns

Promise<void>

---

run()

run(options): Promise<void>

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

Parameters

options

eachMessage

(payload) => Promise<void>

Returns

Promise<void>

---

stop()

stop(): Promise<void>

Defined in: cap-transport-kafka/src/kafka-types.ts:32

Returns

Promise<void>

---

subscribe()

subscribe(options): Promise<void>

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

Parameters

options

replace?

boolean

topics

string[]

Returns

Promise<void>

This site is open source. Improve this page.