跳转到内容
actor-ts
简体中文

KafkaPublish

此内容尚不支持你的语言。

KafkaPublish = object

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

Outbound Kafka publish envelope. key / partition optional.

Properties

Section titled “Properties”

headers?

Section titled “headers?”

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

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

key?

Section titled “key?”

readonly optional key?: Uint8Array | string

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

partition?

Section titled “partition?”

readonly optional partition?: number

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

topic

Section titled “topic”

readonly topic: string

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

value

Section titled “value”

readonly value: Uint8Array | string

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