Trait cloudevents_sdk_rdkafka::MessageExt

pub trait MessageExt: Sealed {
    fn to_event(&self) -> Result<Event>;
}

Extension Trait for Message which acts as a wrapper for the function record_to_event().

This trait is sealed and cannot be implemented for types outside of this crate.

Required methods

fn to_event(&self) -> Result<Event>

Generates Event from BorrowedMessage.

Loading content...

Implementations on Foreign Types

impl<'_> MessageExt for BorrowedMessage<'_>

fn to_event(&self) -> Result<Event>

impl MessageExt for OwnedMessage

fn to_event(&self) -> Result<Event>

Loading content...

Implementors

Loading content...