Skip to content

KafkaPublish

Defined in: src/io/broker/KafkaActor.ts:22

Outbound Kafka publish envelope. key / partition optional.

readonly optional headers?: Readonly<Record<string, string | Uint8Array<ArrayBufferLike>>>

Defined in: src/io/broker/KafkaActor.ts:27


readonly optional key?: string | Uint8Array<ArrayBufferLike>

Defined in: src/io/broker/KafkaActor.ts:25


readonly optional partition?: number

Defined in: src/io/broker/KafkaActor.ts:26


readonly topic: string

Defined in: src/io/broker/KafkaActor.ts:23


readonly value: string | Uint8Array<ArrayBufferLike>

Defined in: src/io/broker/KafkaActor.ts:24