Struct cloudevents_sdk_rdkafka::ConsumerRecordDeserializer

pub struct ConsumerRecordDeserializer { /* fields omitted */ }

Wrapper for Message that implements MessageDeserializer trait.

Implementations

impl ConsumerRecordDeserializer

pub fn new(message: &impl Message) -> Result<ConsumerRecordDeserializer>

Trait Implementations

impl BinaryDeserializer for ConsumerRecordDeserializer

fn deserialize_binary<R: Sized, V: BinarySerializer<R>>(
    self,
    visitor: V
) -> Result<R>

Deserialize the message to BinarySerializer.

fn into_event(self) -> Result<Event, Error>

Convert this Message to Event.

impl MessageDeserializer for ConsumerRecordDeserializer

fn encoding(&self) -> Encoding

Get this message Encoding.

fn into_event(self) -> Result<Event, Error>

Convert this Message to Event.

fn deserialize_to_binary<R, T>(self, serializer: T) -> Result<R, Error> where
    T: BinarySerializer<R>, 

Deserialize the message to BinarySerializer.

fn deserialize_to_structured<R, T>(self, serializer: T) -> Result<R, Error> where
    T: StructuredSerializer<R>, 

Deserialize the message to StructuredSerializer.

fn deserialize_to<R, T>(self, serializer: T) -> Result<R, Error> where
    T: StructuredSerializer<R> + BinarySerializer<R>, 

Deserialize the message to a serializer, depending on the message encoding. You can use this method to transcode this message directly to another serializer, without going through Event.

impl StructuredDeserializer for ConsumerRecordDeserializer

fn deserialize_structured<R: Sized, V: StructuredSerializer<R>>(
    self,
    visitor: V
) -> Result<R>

Deserialize the message to StructuredSerializer.

fn into_event(self) -> Result<Event, Error>

Convert this Message to Event.