Struct RecordBatchDecoder

pub struct RecordBatchDecoder;

Batch decoder for Kafka records.

Implementations

impl RecordBatchDecoder

pub fn decode_with_custom_compression<B: ByteBuf, F>( buf: &mut B, decompressor: Option<F>, ) -> Result<RecordSet>

where F: Fn(&mut Bytes, Compression) -> Result<B>,

Decode one RecordSet from the provided buffer.

Arguments

• decompressor - A function that decompresses the given batch of records.

If None, the right decompression algorithm will automatically be selected and applied.

pub fn decode_all<B: ByteBuf>(buf: &mut B) -> Result<Vec<RecordSet>>

Decode the entire buffer into a vec of RecordSets.

pub fn decode<B: ByteBuf>(buf: &mut B) -> Result<RecordSet>

Decode one RecordSet from the provided buffer.

Trait Implementations

impl Clone for RecordBatchDecoder

fn clone(&self) -> RecordBatchDecoder

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RecordBatchDecoder

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

Formats the value using the given formatter.