KafkaRecord

KafkaRecord = object

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

Inbound Kafka record delivered to subscribers.

Properties

headers

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

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

---

key

readonly key: Uint8Array | null

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

---

offset

readonly offset: string

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

---

partition

readonly partition: number

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

---

timestamp

readonly timestamp: string

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

---

topic

readonly topic: string

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

---

value

readonly value: Uint8Array | null

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