Struct ByteArraySerializer 

#[non_exhaustive]
pub struct ByteArraySerializer;

Serializes byte arrays by passing them through unchanged.

Corresponds to Java’s org.apache.kafka.common.serialization.ByteArraySerializer.

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

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

Convert data into a byte array.

fn serialize_headers( &self, topic: &str, _headers: &RecordHeaders, data: Option<&T>, ) -> Result<Option<Vec<u8>>, Error>

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

impl Serializer<Vec<u8>> for ByteArraySerializer

fn serialize( &self, _topic: &str, data: Option<&Vec<u8>>, ) -> Result<Option<Vec<u8>>, Error>

Convert data into a byte array.

fn serialize_owned_headers( &self, _topic: &str, _headers: &RecordHeaders, data: Option<Vec<u8>>, ) -> Result<Option<Vec<u8>>, Error>

Serialize owned data, avoiding a clone when the input is already bytes.

fn serialize_headers( &self, topic: &str, _headers: &RecordHeaders, data: Option<&T>, ) -> Result<Option<Vec<u8>>, Error>

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