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

    Type Alias KafkaClient

    Duck-typed consumer for tests / custom clients. Return already-fetched messages; columna maps them to rows.

    type KafkaClient = {
        close?: () => void | Promise<void>;
        consume: (
            request: {
                fromBeginning?: boolean;
                maxWaitMs?: number;
                nMessages?: number;
                topic: string;
            },
        ) => Promise<KafkaRawMessage[]>;
    }
    Index
    close? consume
    close?: () => void | Promise<void>
    consume: (
        request: {
            fromBeginning?: boolean;
            maxWaitMs?: number;
            nMessages?: number;
            topic: string;
        },
    ) => Promise<KafkaRawMessage[]>

    Settings
    Member Visibility

    On This Page
    Properties