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

    Type Alias RecordBatchOptions

    Options for building a RecordBatch.

    type RecordBatchOptions = {
        baseOffset?: bigint;
        baseSequence?: number;
        baseTimestamp?: bigint;
        compression?: CompressionCodec;
        isControlBatch?: boolean;
        isTransactional?: boolean;
        partitionLeaderEpoch?: number;
        producerEpoch?: number;
        producerId?: bigint;
        timestampType?: TimestampType;
    }
    Index

    Properties

    baseOffset? baseSequence? baseTimestamp? compression? isControlBatch? isTransactional? partitionLeaderEpoch? producerEpoch? producerId? timestampType?

    Properties

    baseOffset?: bigint

    Base offset for the batch (default: 0).

    baseSequence?: number

    Base sequence number (default: -1).

    baseTimestamp?: bigint

    Base timestamp in milliseconds (default: Date.now()).

    compression?: CompressionCodec

    Compression codec (default: NONE).

    isControlBatch?: boolean

    Whether this is a control batch (default: false).

    isTransactional?: boolean

    Whether this is a transactional batch (default: false).

    partitionLeaderEpoch?: number

    Partition leader epoch (default: -1).

    producerEpoch?: number

    Producer epoch (default: -1).

    producerId?: bigint

    Producer ID for idempotent producers (default: -1).

    timestampType?: TimestampType

    Timestamp type (default: CREATE_TIME).

    Settings

    Member Visibility

    On This Page

    Properties