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.