pub type PbCdcMessage = CdcMessage;
Expand description
Alias for CdcMessage
.
Aliased Type§
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.