R

Redpanda Connect (Benthos)

R
Redpanda Connect (Benthos) Observability v4.116.1

v4.116.1

For installation instructions check out the getting started guide. Added mongodb_cdc: Added incremental snapshot mode with configurable signal collection for on-demand snapshot re-execution alongside streaming changes. (@squiidz, #4996) sftp: Added cache_mode configuration to enable re-consumption of files when their modification time changes in addition to initial consumption. (@rockdatasrl001, #…

R
Redpanda Connect (Benthos) Observability v4.116.0

v4.116.0

For installation instructions check out the getting started guide. Added mongodb_cdc: Added incremental snapshot mode with configurable signal collection for on-demand snapshot re-execution alongside streaming changes. (@squiidz, #4996) sftp: Added cache_mode configuration to enable re-consumption of files when their modification time changes in addition to initial consumption. (@rockdatasrl001, #…

R
Redpanda Connect (Benthos) Observability v4.115.1

v4.115.1

For installation instructions check out the getting started guide. Fixed kafka: The kafka_franz and redpanda outputs no longer append produce errors and record decoration errors to the same slice from two goroutines, removing a data race in the franz writer. (@Jeffail, #5033) kafka: The franz writer now fires the dispatch signal as soon as a record is handed to the producer, restoring the hand-off…

R
Redpanda Connect (Benthos) Observability v4.115.0

v4.115.0

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…

R
Redpanda Connect (Benthos) Observability v4.114.0

v4.114.0

For installation instructions check out the getting started guide. Added kafka: Added optional tombstone field to franz-based Kafka outputs (redpanda, kafka_franz) to support producing compacted topic deletes and null values. (@squiidz, #4959) oracledb_cdc: Exposed rs_id and ssn metadata from Oracle LogMiner to uniquely identify row changes in transactions, following Debezium's field names. (@Lewa…

R
Redpanda Connect (Benthos) Observability v4.113.1

v4.113.1

For installation instructions check out the getting started guide. Added oracledb_cdc: Oracle CDC input now exposes rs_id and ssn metadata to uniquely identify row changes in transactions. (@Leward, #4826) oracledb_cdc: Oracle CDC input now emits row_seq metadata to distinguish rows in bulk DELETE operations where rs_id and ssn are identical. (@Leward, #4827) prometheus: Prometheus exporter docume…

R
Redpanda Connect (Benthos) Observability v4.113.0

v4.113.0

For installation instructions check out the getting started guide. Added sftp: SFTP credentials now support an advanced opt-in block to enable additional SSH key exchange algorithms, ciphers, and MACs beyond the x/crypto/ssh defaults. (@rockdatasrl001, #4906) Fixed license: Community binary now correctly reports an enterprise license error when a user configures an enterprise component without a l…

R
Redpanda Connect (Benthos) Observability v4.112.0

v4.112.0

For installation instructions check out the getting started guide. Added postgres_cdc: Added incremental snapshot support to Postgres CDC, enabling tables to be backfilled in chunks while replication continues running, eliminating the need for snapshot-induced stream blocking or restart from the beginning. (@josephwoodward, #4811) oracledb_cdc: Implemented a log_count based algorithm for the Oracl…

R
Redpanda Connect (Benthos) Observability v4.111.1

v4.111.1

For installation instructions check out the getting started guide. Added oracledb_cdc: Implemented a log_count based algorithm for the Oracle CDC window strategy to improve change capture efficiency. (@josephwoodward, #4864) postgres_cdc: Added support for incremental snapshot backfills that run alongside live replication, allowing tables to be captured in chunks without blocking the replication s…

R
Redpanda Connect (Benthos) Observability v4.111.0

v4.111.0

For installation instructions check out the getting started guide. Added mssqlserver_cdc: Exposed seqval and command_id metadata fields alongside lsn to enable proper ordering of changes within transactions. (@Leward, #4831) oracledb_cdc: Added prefetch_rows configuration option to optimize LogMiner query performance. (@josephwoodward, #4698) websocket: Enabled websocket input and output component…

R
Redpanda Connect (Benthos) Observability v4.110.0

v4.110.0

For installation instructions check out the getting started guide. Added oracledb_cdc: Oracle CDC connector now includes username as metadata in events for better traceability. (@josephwoodward, #4674) Fixed iceberg: Replaced MinIO with silo fork in tests to work around MinIO's removal from Docker Hub. (@Leward, #4819) snowflake_streaming: Fixed offset token comparison to handle unpadded numeric t…

R
Redpanda Connect (Benthos) Observability v4.109.0

v4.109.0

For installation instructions check out the getting started guide. Added avro: Added max_decompressed_block_bytes configuration field to cap OCF block decompression and prevent decompression-bomb denial-of-service attacks. (@Jeffail, #4773) aws_kinesis: Added a poll_period field to bound the rate of GetRecords calls per shard, and an enhanced_fan_out configuration block that consumes streams via a…