Hi everyone, We are pleased to announce the release of Apache Beam version 2.73.0.
This release brings several improvements, new features, and important fixes. You can download the release here: https://beam.apache.org/get-started/downloads/ Key Highlights: DebeziumIO (Java): Added offset persistence via OffsetRetainer to reliably resume CDC pipelines across restarts. BigQuery (Python): Introduced new CDC streaming source for real-time change data ingestion. Python: Added support for Python 3.14 and improved error handling with exception chaining. ML / AI (Python): Added ADKAgentModelHandler for running Google ADK agents and image embedding support in ml.rag. Go SDK: Added OrderedListState support for stateful DoFn processing. Runtime / Options (Python): Enabled large pipeline options via file and added pip_no_build_isolation experiment for dependency control. This release includes breaking changes, particularly around Python SDK container pipeline options handling and stricter DoFn typehint enforcement. Please review the full release notes carefully. For detailed information on all changes, improvements, breaking changes, and bug fixes, please see the full release notes: https://github.com/apache/beam/releases/tag/v2.73.0 Thank you to everyone who contributed to this release! Best regards, The Apache Beam Team
