@qualithm/kafka-client - v0.1.6
    Preparing search index...

    Type Alias FetchRequest

    Fetch request payload.

    type FetchRequest = {
        forgottenTopics?: readonly ForgottenTopic[];
        isolationLevel?: FetchIsolationLevel;
        maxBytes?: number;
        maxWaitMs: number;
        minBytes: number;
        rackId?: string;
        replicaId?: number;
        sessionEpoch?: number;
        sessionId?: number;
        taggedFields?: readonly TaggedField[];
        topics: readonly FetchTopicRequest[];
    }
    Index

    Properties

    forgottenTopics? isolationLevel? maxBytes? maxWaitMs minBytes rackId? replicaId? sessionEpoch? sessionId? taggedFields? topics

    Properties

    forgottenTopics?: readonly ForgottenTopic[]

    Topics to remove from an incremental fetch session (v7+).

    isolationLevel?: FetchIsolationLevel

    Isolation level for transactional reads (v4+).

    maxBytes?: number

    Maximum bytes to return at request level (v3+). Default: 0x7fffffff (MAX_INT32).

    maxWaitMs: number

    Maximum time in milliseconds to wait for data.

    minBytes: number

    Minimum bytes to accumulate before responding.

    rackId?: string

    The consumer's rack ID (v11+).

    replicaId?: number

    The broker ID of the follower (-1 for consumers).

    sessionEpoch?: number

    The fetch session epoch (v7+). -1 for initial requests.

    sessionId?: number

    The fetch session ID (v7+). 0 for full fetches.

    taggedFields?: readonly TaggedField[]

    Tagged fields (v12+).

    topics: readonly FetchTopicRequest[]

    Topics to fetch.

    Settings

    Member Visibility

    On This Page

    Properties