Benthos Files

For installation instructions check out the getting started guide.

Added

• redis: Add configuration option to set client name for redis connections. (@nhaberla)
• benthos: The command processor now emits the exit_code metadata field. (@mihaitodor)
• postgres_cdc: Input now adds schema metadata to consumed messages, this can be used for automatic schema conversion in processors such as schema_registry_encode. (@Jeffail)
• iceberg: New output, allows writing Iceberg data to REST catalogs in s3, gcs and adls. (@rockwotj)
• microsoft_sql_server_cdc: Input now adds schema metadata to consumed messages, this can be used for automatic schema conversion in processors such as schema_registry_encode. (@Jeffail)
• otlp: Add oauth2 support and service account fallback to schemaregistry (@mmatczuk)

Changed

• snowflake_streaming output: the commit polling backoff is now configurable via the commit_backoff object. The commit_timeout field is deprecated in favour of commit_backoff.max_elapsed_time.
• tigerbeetle_cdc input: adds the timeout_seconds configuration and triggers monitoring in case of lost connectivity with the TigerBeetle cluster. (@batiati)

Fixed

• test command: Templates registered via the -t flag are now correctly available during test execution. (@Phantal)
• benthos: Fixed a regression where input and output resources imported but unused were being initialized. (@Jeffail)
• redpanda/migrator: fix key scoping to prevent label collision (@mmatczuk)

The full change log can be found here.