benthosdev/benthos v3.45.0

on GitHub

For installation instructions check out the getting started guide.

Added

• Experimental azure_renew_lock field added to the amqp_1 input.
• New beta root_meta function.
• Field dequeue_visibility_timeout added to the azure_queue_storage input.
• Field max_in_flight added to the azure_queue_storage output.
• New beta Bloblang methods format_timestamp_unix and format_timestamp_unix_nano.
• New Bloblang methods reverse and index_of.
• Experimental extract_tracing_map field added to the kafka input.
• Experimental inject_tracing_map field added to the kafka output.
• Field oauth2.scopes added to HTTP components.
• The mqtt input and output now support TLS.
• Field enable_renegotiation added to tls configurations.
• Bloblang if expressions now support an arbitrary number of else if blocks.

Fixed

• The checkpoint_limit field for the kafka input now works according to explicit messages in flight rather than the actual offset. This means it now works as expected with compacted topics.
• The aws_kinesis input should now automatically recover when the shard iterator has expired.
• Corrected an issue where messages prefixed with valid JSON documents or values were being decoded in truncated form when the remainder was invalid.

Changed

• The following beta components have been promoted to stable:
  • ristretto cache
  • csv and generate inputs
  • reject output
  • branch, jq and workflow processors

The full change log can be found here.