flowly_kafka::message

Trait KafkaMessage

Source 
pub trait KafkaMessage {
    type Key: AsRef<[u8]>;
    type Value;

    // Required methods
    fn key(&self) -> Option<Self::Key>;
    fn value(&self) -> Option<&Self::Value>;
    fn ts_ms_utc(&self) -> Option<i64>;
    fn into_value(self) -> Option<Self::Value>;
}

Required Associated Types§

Source

type Key: AsRef<[u8]>

Source

type Value

Required Methods§

Source

fn key(&self) -> Option<Self::Key>

Source

fn value(&self) -> Option<&Self::Value>

Source

fn ts_ms_utc(&self) -> Option<i64>

Source

fn into_value(self) -> Option<Self::Value>

Implementors§