const CONNECT_MICRO_TS: &str = "io.debezium.time.MicroTimestamp";