Interface KafkaProducerLike

Minimal producer shape used by the Kafka transport.

interface KafkaProducerLike {
    connect(): Promise<void>;
    disconnect(): Promise<void>;
    send(
        record: { messages: { value: string }[]; topic: string },
    ): Promise<unknown>;
}

Index

Methods

connect disconnect send

Methods

connect

connect(): Promise<void>
Connect the producer before publishing records.

Returns Promise<void>
- Defined in packages/kkrpc/src/transports/kafka.ts:55

disconnect

disconnect(): Promise<void>
Disconnect the producer and release network resources.

Returns Promise<void>
- Defined in packages/kkrpc/src/transports/kafka.ts:57

send

send(record: { messages: { value: string }[]; topic: string }): Promise<unknown>
Send one or more records to a Kafka topic.
Parameters
- record: { messages: { value: string }[]; topic: string }
Returns Promise<unknown>
- Defined in packages/kkrpc/src/transports/kafka.ts:59