Streaming CDC at Scale - Beam Summit 2026

Presented by Jiufeng Liu at Beam Summit 2026. Introducing a YAML-driven Dataflow Flex Template design enabling product teams to self-serve Spanner to BigQuery replication, supporting both current-state and append-only modes for analytics, downstream applications, and audit trails. This session focuses on streaming CDC(Change Data Capture) use cases. In a federated deployment model where each product team owns and operates its own pipeline, redeployments emerged as a recurring risk event. None of Dataflow's existing restart mechanisms work perfectly for our use cases, leaving every redeployment risks data loss or duplicate data. A proper fix belongs in Dataflow and SpannerIO. In the meantime, an interim solution has kept redeployments routine in production, with no data loss or duplication. This session covers the problem, the approach, and the tradeoffs that remain.