Struct BytesDeserializer 

#[non_exhaustive]
pub struct BytesDeserializer;

Deserializes byte arrays into refcounted [bytes::Bytes].

This is the zero-copy counterpart to ByteArrayDeserializer: where the latter must copy the borrowed &[u8] into an owned Vec<u8>, BytesDeserializer returns the record’s key/value as the consumer hands it to deserialize_with_headers_bytes: a refcounted slice of the buffer that owns the record’s bytes (consumer-threading.md §27) — the fetched records buffer for an uncompressed batch, the buffer the record was decompressed into for a compressed one. No per-record key/value copy occurs on the receive path.

The plain deserialize entry point (used when no shared buffer is available, e.g. unit tests) still copies via [Bytes::copy_from_slice], matching the §27 “safe copy fallback” contract.

Implementations

impl BytesDeserializer

pub fn new() -> Self

Create a new BytesDeserializer.

Trait Implementations

impl Clone for BytesDeserializer

fn clone(&self) -> BytesDeserializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BytesDeserializer

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

Formats the value using the given formatter.

impl Default for BytesDeserializer

fn default() -> BytesDeserializer

Returns the “default value” for a type.

impl Deserializer<Bytes> for BytesDeserializer

async fn deserialize(&self, _topic: &str, data: &[u8]) -> Result<Bytes, Error>

Deserialize a record value from a byte array into a value or object.

async fn deserialize_with_headers_bytes( &self, _topic: &str, _headers: &mut RecordHeaders, data: &Bytes, ) -> Result<Bytes, Error>

Deserialize a record value from a [Bytes] buffer into a value or object.

fn deserialize_with_headers<'a>( &'a self, topic: &'a str, headers: &'a mut RecordHeaders, data: &'a [u8], ) -> impl Future<Output = Result<T, Error>> + Send + 'a

Deserialize a record value from a byte array into a value or object.

fn configure<'a>( &'a mut self, configs: &'a HashMap<String, String>, is_key: bool, ) -> impl Future<Output = Result<(), Error>> + Send + 'a

Configure this class. The default implementation is a no-op.

fn close(&mut self) -> impl Future<Output = Result<(), Error>> + Send

Close this deserializer.