Benthos Files

For installation instructions check out the getting started guide.

Added

• snowflake: Added snowflake_streaming_pipe output connector with Snowpipe Streaming v2 support, including compression, request splitting, and improved error handling. (@Jeffail, #4834)

Fixed

• docs_gen: Fixed YAML parsing of hex values in generated documentation examples by properly quoting them. (@abhilashmandaliya, #4978)
• deps: Update dependencies to address recent eMudhra vulnerability (@josephwoodward, #5003)

Changed

• oracledb_cdc: Improve performance by skipping schema cache rebuild when column metadata is unchanged. (@josephwoodward, #5007)
• cli: The --rpc-plugins flag now merges values from root and subcommand levels, allowing plugins to be registered at both levels; also added to dry-run command. (@Leward, #4976)
• postgres_cdc: PostgreSQL CDC streaming now batches rows per transaction over a buffered channel with a configurable batch_transactions option, improving throughput while maintaining per-row failure semantics by default. (@squiidz, #4812)
• sap_hana: SAP HANA source now rejects negative max_retries, records table reference in checkpoints to prevent cross-table state sharing, and sanitizes record names for Iceberg targets. (@squiidz, #4983)

The full change log can be found here.