cap-nodejs

CAP Node.js API

---

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

Interface: EachMessagePayload

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:306

Properties

message

message: KafkaMessage

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:309

---

partition

partition: number

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:308

---

topic

topic: string

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:307

Methods

heartbeat()

heartbeat(): Promise<void>

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:310

Returns

Promise<void>

---

pause()

pause(): () => void

Defined in: ../node_modules/@confluentinc/kafka-javascript/types/kafkajs.d.ts:311

Returns

() => void

This site is open source. Improve this page.