cap-nodejs

CAP Node.js API


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

Interface: KafkaProducerClient

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

Methods

connect()

connect(): Promise<void>

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

Returns

Promise<void>


disconnect()

disconnect(): Promise<void>

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

Returns

Promise<void>


send()

send(record): Promise<RecordMetadata[]>

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

Parameters

record
messages

object[]

topic

string

Returns

Promise<RecordMetadata[]>