fn spawn_schema_validator(
client: Client,
config: &RawSourceCreationConfig,
publication: String,
table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
) -> UnboundedReceiver<SchemaValidationError>
fn spawn_schema_validator(
client: Client,
config: &RawSourceCreationConfig,
publication: String,
table_info: BTreeMap<u32, BTreeMap<usize, SourceOutputInfo>>,
) -> UnboundedReceiver<SchemaValidationError>