Benthos v4.10.0 Release Notes
Release Date: 2022-10-26 // about 2 years ago-
โ Added
- ๐ The
nats_jetstream
input now adds a range of useful metadata information to messages. - Field
transaction_type
added to theazure_table_storage
output, which deprecates the previousinsert_type
field and supports interpolation functions. - Field
logged_batch
added to thecassandra
output. - ๐ All
sql
components now support Snowflake. - New
azure_table_storage
input. - ๐ New
sql_raw
input. - ๐ New
tracing_id
bloblang function. - ๐ New
with
bloblang method. - Field
multi_header
added to thekafka
andkafka_franz
inputs. - ๐ New
cassandra
input. - New
base64_encode
andbase64_decode
functions for the awk processor. - ๐ Param
use_number
added to theparse_json
bloblang method. - Fields
init_statement
andinit_files
added to all sql components. - ๐ New
find
andfind_all
bloblang array methods.
๐ Fixed
- The
gcp_cloud_storage
output no longer ignores errors when closing a written file, this was masking issues when the target bucket was invalid. - โฌ๏ธ Upgraded the
kafka_franz
input and output to use github.com/twmb/[email protected] since some bug fixes were made recently. - ๐ Fixed an issue where a
read_until
child input with processors affiliated would block graceful termination. - ๐ The
--labels
linting option no longer flags resource components.
- ๐ The
Previous changes from v4.9.1
-
โ Added
- Go API: A new
BatchError
type added for distinguishing errors of a given batch.
๐ Fixed
- โฌ๏ธ Rolled back
kafka
input and output underlying sarama client library to fix a regression introduced in 4.9.0 ๐ whereinvalid configuration (Consumer.Group.Rebalance.GroupStrategies and Consumer.Group.Rebalance.Strategy cannot be set at the same time)
errors would prevent consumption under certain configurations. We've decided to roll back rather than upgrade as a breaking API change was introduced that could cause issues for Go API importers (more info here: https://github.com/Shopify/sarama/issues/2358).
- Go API: A new