Struct KafkaMessage 

pub struct KafkaMessage {
    pub event_id: String,
    pub subscription_name: String,
    pub entity_type: String,
    pub entity_id: String,
    pub operation: String,
    pub data: Value,
    pub old_data: Option<Value>,
    pub timestamp: String,
    pub sequence_number: u64,
}

Kafka message format for event delivery.

Fields

event_id: String

Unique event identifier.

subscription_name: String

Subscription name.

entity_type: String

Entity type.

entity_id: String

Entity primary key (used as message key).

operation: String

Operation type.

data: Value

Event data.

old_data: Option<Value>

Previous data (for UPDATE operations).

timestamp: String

Event timestamp.

sequence_number: u64

Sequence number.

Implementations

impl KafkaMessage

pub fn from_event(event: &SubscriptionEvent, subscription_name: &str) -> Self

Create a Kafka message from a subscription event.

pub fn key(&self) -> &str

Get the message key (entity_id for partitioning).

Trait Implementations

impl Clone for KafkaMessage

fn clone(&self) -> KafkaMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KafkaMessage

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

Formats the value using the given formatter.

impl Serialize for KafkaMessage

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.