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 slices the owning fetch buffer (deserialize_from_shared) so the returned Bytes shares the single buffer that owns the whole fetch payload (consumer-threading.md §27). No per-record key/value copy occurs on the receive path.

The plain deserialize entry point (used when no shared source 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

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

Deserialize a record value from a byte slice.

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

Deserialize from a byte slice that is a subslice of a refcounted source buffer, enabling zero-copy T for byte-typed deserializers.

fn deserialize_from_shared_headers( &self, _topic: &str, _headers: &dyn Headers, source: &Bytes, data: &[u8], ) -> Result<Bytes, Error>

Header-aware variant of deserialize_from_shared.

fn deserialize_headers( &self, topic: &str, _headers: &dyn Headers, data: &[u8], ) -> Result<T, Error>

Deserialize a record value with access to its headers.

fn configure(&mut self, _configs: &HashMap<String, String>, _is_key: bool)

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

fn close(&mut self)

Close this deserializer. The default implementation is a no-op.