Type Alias Message

A Kafka message to be produced or that has been consumed.

Key and value use Uint8Array per locked decision #2.

type Message = {
    headers?: readonly MessageHeader[];
    key: Uint8Array | null;
    timestamp?: bigint;
    value: Uint8Array | null;
}

Index

Properties

headers? key timestamp? value

Properties

`Optional` `Readonly`headers

headers?: readonly MessageHeader[]

Optional message headers.

`Readonly`key

key: Uint8Array | null

Optional message key for partitioning. null means no key.

`Optional` `Readonly`timestamp

timestamp?: bigint

Timestamp in milliseconds since epoch. Set by producer or broker.

`Readonly`value

value: Uint8Array | null

Message value (payload). null represents a tombstone.