Struct KafkaMessage

pub struct KafkaMessage {
    pub topic: String,
    pub partition: i32,
    pub offset: i64,
    pub key: Option<Vec<u8>>,
    pub value: Option<Vec<u8>>,
    pub timestamp: Option<i64>,
    pub headers: Option<HashMap<String, String>>,
}

Fields

topic: String

partition: i32

offset: i64

key: Option<Vec<u8>>

value: Option<Vec<u8>>

timestamp: Option<i64>

headers: Option<HashMap<String, String>>

Trait Implementations

impl Debug for KafkaMessage

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

Formats the value using the given formatter.

impl Default for KafkaMessage

fn default() -> KafkaMessage

Returns the “default value” for a type.

impl From<OwnedMessage> for KafkaMessage

fn from(v: OwnedMessage) -> Self

Converts to this type from the input type.