Note: This release is being rolled out. It may not be in your region yet.
What's Changed
Additional New Features
- Adding schema loader transform to cdc data generator by @shreyakhajanchi in #3483
- BQ Anomaly detection: Reshuffle fanout in cdc by @claudevdm in #3621
- Make anomaly message configurable by @claudevdm in #3623
- Handle sliding window anomaly detection by @claudevdm in #3622
- Added support for PostgreSQL dialect in reverse replication by @shreyakhajanchi in #3619
Bug fixes
- Update WriteDataChangeRecordsToAvro to support array type. by @jiangzzhu in #3558
- Fix DLQ infinite retry loop via hybrid consumption model by @aasthabharill in #3535
- Remove the default settings.xml to address the credentials decryption failure by @chamikaramj in #3583
- Add unknown exceptions as retryable to DatastreamResourceManager by @aasthabharill in #3602
- Fix machine size in flaky load tests by @aasthabharill in #3585
- Add IT for csv import template - for case when spanner write fails by @aasthabharill in #3606
- [GCS_Avro_to_Cloud_Spanner] Fix GSQL secondary index clause ordering (WHERE before INTERLEAVE IN) by @atask-g in #3595
- [kafka] - remove kafka from v1 pom and add check to kafka workflow by @derrickaw in #3628
- Add IT to test bulk migration using transformation with dropped column in Spanner by @aasthabharill in #3607
Improvements
- Error handling for accidentally providing a Pub/Sub Topic rather than MQTT topic by @svetakvsundhar in #3555
- Added write to GCS incase of failed mutations - Import template by @shreyakhajanchi in #3519
- Add README for validation template by @manitgupta in #3584
- Optimize Kafka sink producer configs for improved batching efficiency by @kir-titievsky-google in #3481
- Upgrade to Beam 2.72.0 by @Abacn in #3557
- remove explicit google ads version by @derrickaw in #3634
- Add pipeline option for Spanner emulator support in SpannerChangeStreamsToPubSub by @hunsche in #3545
New Templates
- PubSub to ClickHouse Flex Template by @BentsiLeviav in #3458
New Contributors
- @pabloqc made their first contribution in #3396
- @lszinv made their first contribution in #3265
- @kir-titievsky-google made their first contribution in #3481
- @hunsche made their first contribution in #3545
Full Changelog: 2026-03-24-00_RC00...2026-04-07-00_RC02