Benthos Files

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.