Struct StringDeserializer 

#[non_exhaustive]
pub struct StringDeserializer;

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

Translation notes

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

Implementations

impl StringDeserializer

pub fn new() -> Self

Create a new StringDeserializer.

Trait Implementations

impl Clone for StringDeserializer

fn clone(&self) -> StringDeserializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StringDeserializer

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

Formats the value using the given formatter.

impl Default for StringDeserializer

fn default() -> StringDeserializer

Returns the “default value” for a type.

impl Deserializer<String> for StringDeserializer

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

Deserialize a record value from a byte array into a value or object.

async fn deserialize_with_headers_bytes( &self, topic: &str, _headers: &mut RecordHeaders, data: &Bytes, ) -> Result<String, Error>

Deserialize a record value from a [Bytes] buffer into a value or object.

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

Deserialize a record value from a byte array into a value or object.

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

Close this deserializer.