For installation instructions check out the getting started guide.
Added
- aws_dynamodb_cdc: DynamoDB CDC now supports Global Tables for checkpoint tables, enabling multi-region failover with low RPO by replicating shard checkpoints across regions. (@squiidz, #4529)
- iceberg: Iceberg output now supports row-level operations (insert/upsert/delete) with configurable mappings and equality-delete files for mutable workloads. (@Jeffail, #4567)
- oracledb_cdc: Oracle CDC now supports snapshot_only mode via a new snapshot_mode enum, replacing the deprecated boolean stream_snapshot option. (@josephwoodward, #4570)
- oracledb_cdc: Oracle CDC snapshot reads now emit commit_ts_ms metadata captured from SYSTIMESTAMP for consistent timestamp tracking. (@josephwoodward, #4571)
- postgres_cdc: Postgres CDC now emits 'before' metadata for update and delete events, enabling change data capture to track previous values. (@josephwoodward, #4555)
Fixed
- oracledb_cdc: Oracle CDC now correctly handles out-of-order LOB writes by deferring and replaying them at commit time. (@josephwoodward, #4574)
- salesforce: Salesforce sink now correctly includes createable fields in the writable field set and makes field cache operation-aware. (@ness-david-dedu, #4553)
- kafka: Broker connectivity failures (connection, read, and write errors such as
i/o timeout) from the franz-go client are now logged at WARN instead of only at debug level, so they can be alerted on without enabling debug logging. Emissions are throttled per broker. Affects all franz-based connectors (kafka_franz,redpanda,redpanda_migrator, ...).
The full change log can be found here.