Function derive_pulsar_message_id_data_column 

pub fn derive_pulsar_message_id_data_column(
    connector_name: &str,
    column_exist: &mut Vec<bool>,
    additional_columns: &mut Vec<ColumnDesc>,
)