Struct StringSerializer 

#[non_exhaustive]
pub struct StringSerializer;

Serializes strings to UTF-8 encoded bytes.

In Java, StringSerializer supports configurable character encodings. In Rust, all String and str values are guaranteed to be valid UTF-8, so this serializer always uses UTF-8 encoding.

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

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

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

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

where T: Sized,

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

impl Serializer<str> for StringSerializer

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