pub fn source_engine(config_path: &str) -> Result<SourceEngine>Expand description
Resolve the config’s source engine into the CDC [SourceEngine] the dedup
view’s __pos parse is keyed on. One config has one source, so this is a
job-wide property. MongoDB is supported too: its change stream carries a
document _id (the dedup partition key) and an order-preserving _data
resume token in __pos, so the current-state view applies just as it does to
the relational engines.