benthosdev/benthos v3.33.0 on GitHub

For installation instructions check out the getting started guide.

Added field codec to the file output.
The file output now supports dynamic file paths.
Added field ttl to the cache processor and output.
New sql output, which is similar to the sql processor and currently supports Clickhouse, PostgreSQL and MySQL.
The kafka input now supports multiple topics, topic partition balancing, and checkpointing.
New cassandra output.
Field allowed_verbs added to the http_server input and output.
New bloblang function now, and method parse_timestamp.
New bloblang methods floor and round.
The bloblang method format_timestamp now supports strings in ISO 8601 format as well as unix epochs with decimal precision up to nanoseconds.

Changed

The files output has been deprecated as its behaviour is now covered by file.
The kafka_balanced input has now been deprecated as its functionality has been added to the kafka input.
The cloudwatch metrics aggregator is now considered stable.
The sequence input is now considered stable.
The switch processor no longer permits cases with no processors.

Fixed the tar and tar-gzip input codecs in experimental inputs.
Fixed a crash that could occur when referencing contextual fields within interpolation functions.
The noop processor can now be inferred with an empty object (noop: {}).
Fixed potential message corruption with the file input when using the lines codec.

The full change log can be found here.