Skip to main content

producer

Workspace API

Workspace API / services/kafka/producer

services/kafka/producer

Functions​

getKafkaProducer()​

getKafkaProducer(): Promise<Producer>

Defined in: services/kafka/producer.ts:16

Get Kafka producer instance (singleton)

Returns​

Promise<Producer>

publishMessage()​

publishMessage(topic, payload, headers?): Promise<{ partition: number; offset: string; }>

Defined in: services/kafka/producer.ts:58

Publish a message to a Kafka topic

Parameters​

topic​

string

Topic name

payload​

any

Message payload (will be JSON stringified)

headers?​

Record<string, string>

Optional message headers (metadata)

Returns​

Promise<{ partition: number; offset: string; }>

Promise resolving to message metadata (partition, offset, etc.)

publishMessages()​

publishMessages(topic, messages): Promise<object[]>

Defined in: services/kafka/producer.ts:110

Publish multiple messages to a Kafka topic (batch)

Parameters​

topic​

string

Topic name

messages​

object[]

Array of messages with payload and optional headers

Returns​

Promise<object[]>

Promise resolving to array of message metadata

disconnectProducer()​

disconnectProducer(): Promise<void>

Defined in: services/kafka/producer.ts:154

Disconnect the producer (for graceful shutdown)

Returns​

Promise<void>