Skip to content

KafkaRecord

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

Inbound Kafka record delivered to subscribers.

readonly headers: Readonly<Record<string, Uint8Array | string | null>>

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


readonly key: Uint8Array<ArrayBufferLike> | null

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


readonly offset: string

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


readonly partition: number

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


readonly timestamp: string

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


readonly topic: string

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


readonly value: Uint8Array<ArrayBufferLike> | null

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