Type Alias PbCdcMessage 

pub type PbCdcMessage = CdcMessage;

Aliased Type

pub struct PbCdcMessage {
    pub payload: String,
    pub partition: String,
    pub offset: String,
    pub full_table_name: String,
    pub source_ts_ms: i64,
    pub msg_type: i32,
    pub key: String,
}

Fields

payload: String

The value of the Debezium message

partition: String

offset: String

full_table_name: String

source_ts_ms: i64

msg_type: i32

key: String

The key of the Debezium message, which only used by mongodb-cdc connector.