Hey folks, My name is Thiago and I am part of the Spanner team at Google. My teammates (Zoe and Hengfeng) and I would like to work on adding the support for Change Streams (CDC) to the SpannerIO connector implementation in Java.
We have created a Jira ticket ( https://issues.apache.org/jira/browse/BEAM-12164) for such purpose and would appreciate it if you could assign the ticket to me. We have been discussing the design of this implementation with other people from Google, which are part of the Dataflow / Beam team (Boyuan and Niel, cced here). Let me know if you have any questions or need any additional information from us. Thanks!
