pub fn decode_cdcv2<G: Scope<Timestamp = Timestamp>>( stream: &Stream<G, SourceOutput<Option<Vec<u8>>, Option<Vec<u8>>>>, schema: &str, registry: Option<ClientConfig>, confluent_wire_format: bool) -> (Collection<G, Row, Diff>, Box<dyn Any>)