Trait cloudevents_sdk_rdkafka::MessageExt

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

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

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...