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

    Type Alias RecordBatch

    A Kafka RecordBatch (magic=2).

    This is the on-wire format for batches of records in Kafka 0.11+.

    type RecordBatch = {
        attributes: RecordBatchAttributes;
        baseOffset: bigint;
        baseSequence: number;
        baseTimestamp: bigint;
        crc: number;
        lastOffsetDelta: number;
        magic: number;
        maxTimestamp: bigint;
        partitionLeaderEpoch: number;
        producerEpoch: number;
        producerId: bigint;
        records: readonly Record[];
    }
    Index

    Properties

    attributes baseOffset baseSequence baseTimestamp crc lastOffsetDelta magic maxTimestamp partitionLeaderEpoch producerEpoch producerId records

    Properties

    attributes: RecordBatchAttributes

    Batch attributes (compression, timestamp type, transactional).

    baseOffset: bigint

    Base offset in the partition log.

    baseSequence: number

    Base sequence number, or -1 if not using idempotent producer.

    baseTimestamp: bigint

    Base timestamp (milliseconds since epoch).

    crc: number

    CRC-32C of the record batch data (from attributes through records).

    lastOffsetDelta: number

    Offset delta of the last record in the batch.

    magic: number

    Magic byte (always 2 for this format).

    maxTimestamp: bigint

    Max timestamp in the batch.

    partitionLeaderEpoch: number

    Partition leader epoch at the time of append.

    producerEpoch: number

    Producer epoch, or -1 if not using idempotent producer.

    producerId: bigint

    Producer ID for idempotent/transactional producers, or -1 if none.

    records: readonly Record[]

    Records in this batch.

    Settings

    Member Visibility

    On This Page

    Properties