basalt / queue-kafka/src / KafkaProducer

Interface: KafkaProducer

Defined in: queue-kafka/src/index.ts:15

Methods

connect()

> connect(): Promise<void>

Defined in: queue-kafka/src/index.ts:16

Returns

Promise<void>

---

disconnect()

> disconnect(): Promise<void>

Defined in: queue-kafka/src/index.ts:21

Returns

Promise<void>

---

send()

> send(record): Promise<unknown>

Defined in: queue-kafka/src/index.ts:17

Parameters

record

messages

object[]

topic

string

Returns

Promise<unknown>