columna API reference - v0.5.0
    Preparing search index...

    Type Alias KafkaRawMessage

    One consumed Kafka record before row mapping.

    type KafkaRawMessage = {
        headers?: Record<string, Buffer | string | undefined>;
        key: Buffer | string | null;
        offset: string;
        partition: number;
        timestamp: string | number;
        topic: string;
        value: Buffer | string | null;
    }
    Index
    headers?: Record<string, Buffer | string | undefined>
    key: Buffer | string | null
    offset: string
    partition: number
    timestamp: string | number
    topic: string
    value: Buffer | string | null