risingwave_pb::connector_service

Type Alias PbCdcMessage

source
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.