Struct RecordBatch 

pub struct RecordBatch {
    pub base_offset: i64,
    pub partition_leader_epoch: i32,
    pub magic: i8,
    pub attributes: i16,
    pub last_offset_delta: i32,
    pub first_timestamp: i64,
    pub max_timestamp: i64,
    pub producer_id: i64,
    pub producer_epoch: i16,
    pub base_sequence: i32,
    pub records: Vec<Record>,
}

A Kafka record batch (message format v2).

batchLength and crc are not stored — they are derived during encode and validated during decode.

Fields

base_offset: i64

Offset of the first record in the batch.

partition_leader_epoch: i32

Partition leader epoch (KIP-101).

magic: i8

Format version. Always 2 for v2 batches.

attributes: i16

Bit-packed flags: compression (bits 0–2), timestamp type (bit 3), transactional (bit 4), control (bit 5).

last_offset_delta: i32

Difference between the first and last record offsets.

first_timestamp: i64

Wall-clock timestamp of the first record.

max_timestamp: i64

Wall-clock timestamp of the record with the highest timestamp.

producer_id: i64

Producer ID (idempotent / transactional producer).

producer_epoch: i16

Producer epoch (idempotent / transactional producer).

base_sequence: i32

First sequence number in the batch (idempotent producer).

records: Vec<Record>

Records in the batch.

Implementations

impl RecordBatch

pub fn encode(&self, buf: &mut BytesMut) -> Result<()>

Encode this batch into buf, including the 12-byte log overhead, CRC32C, and any compression dictated by self.attributes.

pub fn encode_with_compression_level( &self, buf: &mut BytesMut, compression_level: Option<i32>, ) -> Result<()>

Encode this batch, passing an optional codec-specific compression level.

pub fn uncompressed_encoded_len(&self) -> Result<usize>

Return the exact encoded length when records are written without compression.

pub fn decode(buf: &mut Bytes) -> Result<Self>

Decode one batch from buf. Validates CRC32C, decompresses if needed, and rejects a record_count above super::MAX_RECORDS_PER_BATCH.

pub fn compression(&self) -> Result<Compression>

Compression codec selected by bits 0–2 of attributes.

pub const fn timestamp_type(&self) -> TimestampType

Timestamp type from bit 3 of attributes.

pub const fn is_transactional(&self) -> bool

true if bit 4 of attributes is set.

pub const fn is_control_batch(&self) -> bool

true if bit 5 of attributes is set.

Trait Implementations

impl Clone for RecordBatch

fn clone(&self) -> RecordBatch

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RecordBatch

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Eq for RecordBatch

impl PartialEq for RecordBatch

fn eq(&self, other: &RecordBatch) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RecordBatch