Struct kafka_api::record::RecordBatch

pub struct RecordBatch { /* private fields */ }

Implementations

impl RecordBatch

pub fn set_last_offset(&mut self, offset: i64)

pub fn base_offset(&self) -> i64

pub fn last_offset_delta(&self) -> i32

pub fn records_count(&self) -> i32

pub fn records(&self) -> Vec<Record>

Trait Implementations

impl Clone for RecordBatch

fn clone(&self) -> RecordBatch

Returns a copy 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 Default for RecordBatch

fn default() -> RecordBatch

Returns the “default value” for a type.