Struct StringSerializer 

#[non_exhaustive]
pub struct StringSerializer;

String encoding defaults to UTF8 and can be customized by setting the property key.serializer.encoding, value.serializer.encoding or serializer.encoding. The first two take precedence over the last.

Translation notes

WARNING: the encoding is always UTF-8; the properties are ignored.

Implementations

impl StringSerializer

pub fn new() -> Self

Create a new StringSerializer.

Trait Implementations

impl Clone for StringSerializer

fn clone(&self) -> StringSerializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StringSerializer

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

Formats the value using the given formatter.

impl Default for StringSerializer

fn default() -> StringSerializer

Returns the “default value” for a type.

impl Serializer<String> for StringSerializer

async fn serialize<'a>( &'a self, _topic: &'a str, data: Option<&'a String>, ) -> 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<str> for StringSerializer

async fn serialize<'a>( &'a self, _topic: &'a str, data: Option<&'a str>, ) -> 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.