Struct ByteArraySerializer 

#[non_exhaustive]
pub struct ByteArraySerializer;

Serializes byte arrays by passing them through unchanged.

The serialized bytes borrow the input (Cow::Borrowed): Java returns the input byte[] itself, and this neither allocates nor copies.

Implementations

impl ByteArraySerializer

pub fn new() -> Self

Create a new ByteArraySerializer.

Trait Implementations

impl Clone for ByteArraySerializer

fn clone(&self) -> ByteArraySerializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ByteArraySerializer

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

Formats the value using the given formatter.

impl Default for ByteArraySerializer

fn default() -> ByteArraySerializer

Returns the “default value” for a type.

impl Serializer<[u8]> for ByteArraySerializer

async fn serialize<'a>( &'a self, _topic: &'a str, data: Option<&'a [u8]>, ) -> Result<Option<Cow<'a, [u8]>>, Error>

Convert data into a byte array.

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

where 'a: 'h,

Convert data into a byte array, with access to the record headers.

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(&self) -> impl Future<Output = Result<(), Error>> + Send + '_

Close this serializer.

impl Serializer<Vec<u8>> for ByteArraySerializer

async fn serialize<'a>( &'a self, _topic: &'a str, data: Option<&'a Vec<u8>>, ) -> Result<Option<Cow<'a, [u8]>>, Error>

Convert data into a byte array.

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

where 'a: 'h,

Convert data into a byte array, with access to the record headers.

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(&self) -> impl Future<Output = Result<(), Error>> + Send + '_

Close this serializer.