Struct Record 

pub struct Record {
    pub attributes: i8,
    pub timestamp_delta: i64,
    pub offset_delta: i32,
    pub key: Option<Bytes>,
    pub value: Option<Bytes>,
    pub headers: Vec<RecordHeader>,
}

A Kafka record within a batch.

Fields

attributes: i8

Record attributes (currently unused in v2).

timestamp_delta: i64

Timestamp delta from batch base timestamp.

offset_delta: i32

Offset delta from batch base offset.

key: Option<Bytes>

Record key.

value: Option<Bytes>

Record value.

headers: Vec<RecordHeader>

Record headers.

Implementations

impl Record

pub fn new(key: Option<Bytes>, value: Option<Bytes>) -> Self

Create a new record with key and value.

pub fn with_header(self, key: impl Into<Bytes>, value: impl Into<Bytes>) -> Self

Add a header to the record.

pub fn with_timestamp_delta(self, delta: i64) -> Self

Set timestamp delta.

pub fn with_offset_delta(self, delta: i32) -> Self

Set offset delta.

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

Encode the record to a buffer.

Pre-computes the body size analytically so no intermediate allocation is needed — the length varint is written first, then the body is encoded directly into the output buffer.

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

Compute the wire-encoded size of the record body (everything after the length prefix). Used by encode to avoid a temporary allocation.

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

Decode a record from a buffer.

Trait Implementations

impl Clone for Record

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Record

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

Formats the value using the given formatter.

impl Eq for Record

impl PartialEq for Record

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Record