Struct KafkaEventMessage 

pub struct KafkaEventMessage<E>
where
    E: Clone + Debug,
{
    pub event: EventEnvelope<E>,
    pub message: OwnedMessage,
}

A message received from Kafka including the event and raw Kafka message.

Fields

event: EventEnvelope<E>

Deserialized event.

message: OwnedMessage

Kafka message received.

Implementations

impl<E> KafkaEventMessage<E>

where E: Clone + Debug,

pub fn map_event<EE, F>(self, f: F) -> KafkaEventMessage<EE>

where EE: Clone + Debug, F: FnOnce(E) -> EE,

Map an event to a new type whilst preserving the rest of the envelope data.

Trait Implementations

impl<E> Clone for KafkaEventMessage<E>

where E: Clone + Debug + Clone,

fn clone(&self) -> KafkaEventMessage<E>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> Debug for KafkaEventMessage<E>

where E: Clone + Debug + Debug,

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

Formats the value using the given formatter.