redpanda-data/connect v4.23.0

on GitHub

For installation instructions check out the getting started guide.

Added

• The amqp_0_9 output now supports dynamic interpolation functions within the exchange field.
• Field custom_topic_creation added to the kafka output.
• New Bloblang method ts_sub.
• The Bloblang method abs now supports integers in and integers out.
• Experimental extract_tracing_map field added to the nats, nats_jetstream and nats_stream inputs.
• Experimental inject_tracing_map field added to the nats, nats_jetstream and nats_stream outputs.
• New _fail_fast variants for the broker output fan_out and fan_out_sequential patterns.
• Field summary_quantiles_objectives added to the prometheus metrics exporter.
• The metric processor now supports floating point values for counter_by and gauge types.

Fixed

• Allow labels on caches and rate limit resources when writing configs in CUE.
• Go API: log/slog loggers injected into a stream builder via StreamBuilder.SetLogger should now respect formatting strings.
• All Azure components now support container SAS tokens for authentication.
• The kafka_franz input now provides properly typed metadata values.
• The trino driver for the various sql_* components no longer panics when trying to insert nulls.
• The http_client input no longer sends a phantom request body on subsequent requests when an empty payload is specified.
• The schema_registry_encode and schema_registry_decode processors should no longer fail to obtain schemas containing slashes (or other URL path unfriendly characters).
• The parse_log processor no longer extracts structured fields that are incompatible with Bloblang mappings.
• Fixed occurrences where Bloblang would fail to recognise float32 values.

The full change log can be found here.