Struct kafka_protocol::records::RecordBatchEncoder

pub struct RecordBatchEncoder;

Batch encoder for Kafka records.

Implementations

impl RecordBatchEncoder

pub fn encode<'a, B, I>( buf: &mut B, records: I, options: &RecordEncodeOptions, ) -> Result<(), EncodeError>

where B: ByteBufMut, I: Iterator<Item = &'a Record> + Clone,

Encode records into given buffer, using provided encoding options that select the encoding strategy based on version.

Trait Implementations

impl Clone for RecordBatchEncoder

fn clone(&self) -> RecordBatchEncoder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RecordBatchEncoder

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

Formats the value using the given formatter.