Releases: rabbitmq/rabbitmq-server
RabbitMQ 4.3.0-rc.0
RabbitMQ 4.3.0-rc.0 is a preview of a new feature release.
Breaking Changes and Compatibility Notes
Mnesia and Parition Handling Strategies are Removed
Since only 4.2.x clusters can upgrade to 4.3.0 in place, this
won't be a breaking change for nearly all instalations but it will affect community
plugins that use Mnesia.
All partition handling-related keys in rabbitmq.conf will be
accepted by 4.3.0 nodes but won't have any effect:
cluster_partition_handlingcluster_partition_handling.pause_if_all_down.recovercluster_partition_handling.pause_if_all_down.nodes.$name
Still, Team RabbitMQ recommends removing the above keys from rabbitmq.conf before or shortly
after upgrading.
Classic Queues v1 Storage (CQv1) is Removed
This release removes the original classic queue storage implementation these days
known as CQv1. A 2nd generation implementation called CQv2 has been adopted
as the default starting with 4.2.0.
This means that attempts to declare a queue using the following optional queue arguments will fail:
x-queue-modeset to any valuex-queue-versionset to1
Existing classic queues upgraded to CQv2 during an earlier upgrade to 4.2.x will continue
operating as usual.
Consumer Timeouts are No Longer Evaluated for Classic Queues and Streams
This release moves consumer timeout handling responsibility into the queues
themselves. Also, all protocols (except the stream protocol) now evaluate
consumer timeout for queue types that support them. Classic queues and streams
never evaluate consumer timeouts as their use cases cause less demand for it.
Release Highlights
Khepri is Now The Only Metadata Store
As of this release, Khepri is the only metadata store supported
by RabbitMQ: Mnesia was removed completely.
In practical operational terms, this means that
- For a cluster to be available, a majority of nodes must be online at all times
- Failure and partition recovery in a RabbitMQ cluster is now significantly
simpler and uniform: all components that have replicated state (Khepri, quorum queues, streams)
recover per Raft recovery semantics
Quorum Queues Enhancements
This release upgrades the Ra dependency to 3.x and introduces
a new (8th) version of the quorum queue state machine with several new features and optimisations:
- Strict priority queues with per-priority message counts, correct
redelivery ordering, and priority-aware message expiration - Delayed retry for quorum queues: configurable increasing backoff when
messages are returned - Consumer timeout for quorum queues: configurable timeout for
unacknowledged messages, with protocol-specific handling for AMQP 1.0 and
MQTT - Recovery snapshots and snapshot throttling to reduce recovery time
and improve snapshotting decisions - Memory optimisations including compact message references, optimised
tuple storage for delayed keys, and removal ofrabbit_fifo_indexusage
Upgrading to 4.3.0
Documentation guides on upgrades
See the Upgrading guide for documentation on upgrades and GitHub releases
for release notes of individual releases.
This release series supports upgrades from 4.2.x. Upgrades from earlier series are not supported:
users must upgrade to the latest available 4.2.x patch release before upgrading to 4.3.0.
New Required Feature Flags
All feature flags introduced in 4.2.0 and earlier are required, including the following:
rabbitmq_4.2.0rabbitmq_4.1.0rabbitmq_4.0.0khepri_dbquorum_queue_non_votersmessage_containers_deaths_v2
Enable all required feature flags before upgrading to 4.3.0.
If your RabbitMQ cluster had plugin rabbitmq_amqp1_0 enabled in RabbitMQ 3.13.x (and your cluster still serves AMQP 1.0 client connections in 4.x), your cluster should do at least one rolling update after enabling feature flag rabbitmq_4.0.0 but before upgrading to 4.3.0.
Deprecated Features
In 4.3.0 the deprecation phase of the following features advanced from permitted_by_default to denied_by_default:
amqp_address_v1amqp_filter_set_bugglobal_qosqueue_master_locatortransient_nonexcl_queues
And the deprecated feature ram_node_type has been removed.
Mixed version cluster compatibility
RabbitMQ 4.3.0 nodes can run alongside 4.2.x in the same cluster.
Mixed version clusters are a mechanism that allows rolling upgrades and are not meant to be run for extended
periods of time (no more than a few hours).
Recommended Post-upgrade Procedures
This version does not require any additional post-upgrade procedures
compared to other versions.
Changes Worth Mentioning
Core Server
Enhancements
-
When a message is rejected by a queue, RabbitMQ now provides the queue name and rejection reason to AMQP 1.0 publishers
in theRejectedoutcome. This is particularly useful when multiple queues are bound to an exchange, as it allows
publishers to identify which specific queue out of several target queues rejected the message and why
(e.g., maximum queue length reached or queue unavailable). Previously, publishers had no way to determine which queue
rejected their message or the reason for rejection.The queue name and reason are included in the
infofield of theRejectedoutcome'serrorfield:queue: <queue name>reason: maxlen | unavailable
GitHub issue: #15075
-
Quorum queues now support strict priority queues with per-priority message counts,
correct redelivery ordering across priorities, and priority-aware message expiration scans.GitHub issue: #13885
-
Quorum queues now support delayed retry with configurable backoff based on delivery count. When messages
are returned (via reject, nack, or modify), they can be held in a delayed state before becoming
available again. The delay is based on delivery count:min(min_delay * delivery_count, max_delay).Configuration is available via queue arguments (
x-delayed-retry-type,x-delayed-retry-min,
x-delayed-retry-max) or policy keys (delayed-retry-type,delayed-retry-min,
delayed-retry-max). The retry type can be set todisabled,all,failed, orreturned.GitHub issue: #13885
-
Quorum queues now support a configurable consumer timeout. When a consumer holds unacknowledged
messages beyond the timeout, the messages are returned to the queue. For AMQP 1.0 clients,
timed-out deliveries are released viaDISPOSITION(state=released)instead of detaching the link,
allowing the consumer to recover without re-attaching. MQTT consumers are also supported.The timeout can be set via the
x-consumer-timeoutconsumer argument, queue argument,consumer-timeout
policy key, or the globalconsumer_timeoutsetting inrabbitmq.conf.GitHub issue: #13885
-
A new
consumer_disconnected_timeoutsetting controls how long quorum queues wait before returning
messages when a consumer's node becomes unreachable due to a network partition. The default is 60 seconds.
Configurable viaconsumer_disconnected_timeoutinrabbitmq.conf, theconsumer-disconnected-timeout
policy key, or thex-consumer-disconnected-timeoutqueue argument.GitHub issue: #13885
-
Quorum queue recovery snapshots reduce recovery time after a member restart by avoiding
the need to replay all enqueue commands from the log.GitHub issue: #13885
-
Quorum queue snapshot throttling now uses WAL fill ratio and reclaimable byte tracking
to make smarter snapshotting decisions, yielding roughly one snapshot per queue per WAL cycle
instead of excessive snapshots in shallow, fast-flowing queues.GitHub issue: #13885
-
Quorum queue memory optimisations: message references now use a compact packed integer
representation ("compact" means up to 59-bit) when possible, halving per-message
memory overhead in many scenarios. Therabbit_fifo_indexmodule is no longer used by the
main state machine.GitHub issue: #13885
-
Quorum queues now allow unlimited explicit message returns. The delivery limit is based on
delivery-countrather thanacquired-count, so messages can be explicitly returned to the
queue without counting towards the delivery limit.GitHub issue: #13885
-
When quorum queue members (replicas) are deleted from a node, either manually
viarabbitmq-queues shrinkor as part ofrabbitmqctl forget_cluster_node,
the members are stopped in parallel.GitHub issue: #15081
-
Purging a quorum queue now also removes at-least-once dead-lettered messages that were pending delivery.
GitHub issue: #13885
Bug Fi...
RabbitMQ 4.2.5
RabbitMQ 4.2.5 is a maintenance release in the 4.2.x release series.
It is strongly recommended that you read 4.2.0 release notes
in detail if upgrading from a version prior to 4.2.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Classic queues could terminate and restart during recovery in certain rare conditions.
GitHub issue: #15595
-
Quorum queues could incorrectly reject messages during deletion.
GitHub issue: #15554
-
Peer discovery could run into a crash when
rabbit_nodes:list_members/0returned
an empty list due to an error or a timeout.GitHub issue: #15568
-
Definition import now strips a leading UTF-8 BOM if the input file has one.
-
Exceptions thrown by decorator callbacks (such as those used by federation)
during policy change notifications were silently suppressed. They are now logged.GitHub issue: #15525
Enhancements
-
Improved Mnesia-to-Khepri migration throughput.
GitHub issue: #15480
-
Additional aten settings are now exposed in
rabbitmq.conf.
Previously only the poll interval was configurable.GitHub issue: #15564
Stream Plugin
Bug Fixes
-
parse_command/1crashed with afunction_clauseerror when receiving a zero-size frame,
such as those sent by load balancer probes or port scanners.GitHub issue: #15703
-
rabbit_stream_managercould crash with acase_clauseerror when a stream declaration
failed due to a metadata store timeout.GitHub issue: #15699
Enhancements
-
Less log noise from load balancer and port scanner probes (that do not perform an AMQP 1.0 or AMQP 0-9-1 handshake)
GitHub issue: #15715
Management Plugin
Bug Fixes
-
Request bodies above the configured maximum limit are now rejected earlier.
GitHub issue: #15712
-
Validation improvements for several API endpoints.
They now ignore node names that do not refer to existing cluster members,
reject unknown fields, etc. -
Queue API responses now include policy-related fields (
policy,operator_policy,
effective_policy_definition) anddelivery_limitwhen management stats collection
is disabled viarabbitmq.conf.
CLI Tools
Bug Fixes
-
rabbitmq-diagnostics statusandrabbitmqctl statuscrashed when targeting a node
in maintenance mode becausevm_memory_high_watermarkwasnil
(thevm_memory_monitorprocess does not run in that state).
Enhancements
-
rabbitmq-pluginsnow produces a clearer error message when run by a non-rootuser.GitHub issue: #15701
Federation Management Plugin
Bug Fixes
-
The
x-internal-purposeandconsumer_timeoutargument values are now correctly escaped.
Prometheus Plugin
Bug Fixes
-
Per-object metrics endpoint (
/metrics/per-object) no longer emits duplicateHELP
andTYPEmetadata lines for Raft metrics when both quorum queues and Khepri are in use,
which caused scraper parser errors.
Grafana Dashboards
Enhancements
-
The
Overviewdashboard's "TCP sockets available" panel was replaced with a "File descriptors available" panel
that uses two modern metrics,rabbitmq_process_max_fdsandrabbitmq_process_open_fds.
Shovel Plugin
Bug Fixes
-
An attempt to declare a dynamic shovel with multiple
src-queue-argsordest-queue-argsvalues
configured could run into an exception during validation.
Web STOMP Plugin
Bug Fixes
-
A terminated heartbeat monitor process could cause a crash during connection shutdown.
GitHub issue: #15607
Dependency Changes
None in this release.
RabbitMQ 4.2.4
RabbitMQ 4.2.4 is a maintenance release in the 4.2.x release series.
It is strongly recommended that you read 4.2.0 release notes
in detail if upgrading from a version prior to 4.2.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Classic queue message store could run into an exception when a file was concurrently deleted by a compaction operation.
GitHub issue: #15411
-
rabbit_quorum_queue:stat/2could fail when the quorum queue leader was undefined. -
The
amq.rabbitmq.logexchange is now declared unconditionally at node boot,
avoiding a potential deadlock between feature flag enablement and logging to the exchange sink.GitHub issue: #15320
MQTT Plugin
Bug Fixes
-
Variable interpolation in topic permissions now.
escapes the special regular expression characters before interpolation.GitHub issue: #15442
Stream Plugin
Bug Fixes
-
Single Active Consumer coordinator
could deadlock when a consumer being deactivated would lose its connection, leaving the consumer group
without an active consumer.GitHub issue: #15353
Management Plugin
Bug Fixes
-
The Policies page in the management UI incorrectly displayed quorum queue arguments
twice on the declaration form in place of stream queue arguments.GitHub issue: #15335
-
The clustering listener now correctly reports its TLS enablement status.
GitHub issue: #15399
Enhancements
-
GET /api/overviewandGET /api/nodesnow report crypto library (such as OpenSSL) version.GitHub issue: #15468
-
RabbitMQ and Erlang/OTP versions are now included in
GET /api/nodesresponses.GitHub issue: #15454
-
Login page usability improvements: autofocus on the username field and
autocompleteattributes
for browser password manager integration.GitHub issue: #15398
CLI Tools
Enhancements
-
rabbitmq-upgrade has_reached_target_cluster_sizeis a new command that checks whether
the cluster has reached its target size, as provided inrabbitmq.conf.This is useful for automating rolling upgrades, particularly on Kubernetes.
GitHub issue: #15404
Shovel Plugin
Bug Fixes
-
Stopping and deleting a shovel could fail with a
badmatchexception
when the underlying worker process no longer existed.GitHub issue: #15408
Trust Store Plugin
Enhancements
-
HTTPS endpoint requests now have a configurable timeout (20 seconds by default),
preventing the plugin from hanging indefinitely when a provider fails to respond.
AWS Peer Discovery Plugin
Bug Fixes
-
Nodes on EC2 instances in non-running states (
stopping,stopped,shutting-down,terminated)
are now filtered out from peer discovery results.GitHub issue: #15388
Enhancements
-
Multiple hostname resolution paths can now be configured. This is an upgrade pathway
for scenarios where resolution hostnames have to change.GitHub issue: #14705
Tracing Plugin
Bug Fixes
-
The plugin now uses UTF-8 encoding for traced messages.
GitHub issue: #15439
Dependency Changes
rawas upgraded to2.17.2
RabbitMQ 4.2.3
RabbitMQ 4.2.3 is a maintenance release in the 4.2.x release series.
It is strongly recommended that you read 4.2.0 release notes
in detail if upgrading from a version prior to 4.2.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Default queue type handling is now more defensive, avoiding an issue where
attempts to declare a queue in a virtual host without any DQT set would result
in aPRECONDITION_FAILEDexception instead of falling back to the classic queue type
for DQT. -
Classic queue recovery on Windows could fail due to an OS-specific file locking behavior.
Such failures are now retried in two more contexts.GitHub issue: #15136
-
Certain exchange update operations in Khepri could cause severe contention.
GitHub issue: #15236
-
Topic exchange binding deletions could leave orphaned trie edges in the Khepri projection,
potentially causing a slowly creeping memory leak.GitHub issue: #15025
-
When a client that owns an exclusive queue disconnects and immediately reconnects and redeclares the same queue
(under the same name), RabbitMQ node could delete the new queue depending on the timing of events.Previously the only workaround was to use exclusive server-named queues for clients that exhibited
this behavior. Now RabbitMQ nodes take internal owner identity into account and will remove
the original queue but not the new one.GitHub issue: #15276
-
"Other ETS" and "Other system" memory metrics could end up being reported as negative values
due to concurrent ETS table updates, deletion and creation on the node.GitHub issue: #15289
-
mirrored_supervisor:child/2could fail with abadmatchexception
when a significant enough number of shovels (or federation links) was removed.GitHub issue: #15229
-
Quorum queue could run into a logging exception during node drain.
GitHub issue: #15212
Enhancements
-
Topic binding deletion in Khepri is now significantly more efficient.
Deleting 100k topic bindings could previously take up to 30 minutes and now takes
some 3-4 seconds.GitHub issue: #15214
-
It is now possible to
rabbitmq-queues shrinkonly a subset of quorum queues on
a node using a pattern (a regex).GitHub issue: #15021
-
CRL (Certificate Revocation List) cache can now be configured via
rabbitmq.conf.
Federation Plugins
Bug Fixes
-
Restored exchange federation compatibility in mixed 4.2.x/4.1.x multi-node clusters.
GitHub issue: #15252
Enhancements
-
Federation links and their connections are now stopped in parallel.
This significantly improves shutdown time for nodes with many (into thousands) federation links.
GitHub issue: #15271
-
Federation links no longer restart during plugin or node shutdown.
For nodes with hundreds or thousands of federation links, link recovery could
significantly delay node shutdown.GitHub issue: #15258
-
Federation links use AMQP 0-9-1 connections to remote nodes (clusters).
Previously the timeout used when those connections are closed was fixed to 10 seconds.
Now it is configurable viarabbitmq.confin milliseconds:# 3 seconds for exchange federation federation.exchanges.connection_close_timeout = 3000 # 3 seconds for queue federation federation.queues.connection_close_timeout = 3000
The maximum supported value is 5 seconds (5000 ms).
GitHub issue: #15268
CLI Tools
Enhancements
-
rabbitmq-streams growandrabbitmq-streams shrinkare new commands that mirror existing
rabbitmq-queues growandrabbitmq-queues shrinkfunctionality for streams.GitHub issue: #15189
MQTT Plugin
Enhancements
-
A new configuration option,
mqtt.disconnect_on_unauthorized, controls whether
MQTT connections are closed upon authorization failures (for example, an attempt to
consume from a topic the client has no permission for).When set to
false, the connection remains open and an appropriate protocol-level
response is sent to the client instead.The default value is
true, same as RabbitMQ MQTT implementation's historic behavior.GitHub issue: #15201
Management Plugin
Bug Fixes
-
OAuth 2:
preferred_auth_mechanismandstrict_auth_mechanismare no longer validated
when not used (configured).GitHub issue: #15148
etcd Peer Discovery Plugin
Bug Fixes
-
When credentials were provided, the password was double-encrypted, resulting in
etcd authentication failures.GitHub issue: #15191
HTTP Auth Backend Plugin
Bug Fixes
-
The
customize_hostname_checkTLS option was unintentionally ignored.GitHub issue: #15184
Dependency Changes
RabbitMQ 4.1.8
RabbitMQ 4.1.8 is a maintenance release in the 4.1.x release series.
It is strongly recommended that you read 4.1.0 release notes
in detail if upgrading from a version prior to 4.1.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Classic queue recovery on Windows could fail due to an OS-specific file locking behavior.
Such failures are now retried in two more contexts.GitHub issue: #15136
-
Default queue type handling is now more defensive, avoiding an issue where
attempts to declare a queue in a virtual host without any DQT set would result
in aPRECONDITION_FAILEDexception instead of falling back to the classic queue type
for DQT.
GitHub issues: #11541, #12109, #12821, #13837
-
Topic exchange binding deletions could leave orphaned trie edges in the Khepri projection,
potentially causing a slowly creeping memory leak.GitHub issue: #15025
-
When a client that owns an exclusive queue disconnects and immediately reconnects and redeclares the same queue
(under the same name), RabbitMQ node could delete the new queue depending on the timing of events.Previously the only workaround was to use exclusive server-named queues for clients that exhibited
this behavior. Now RabbitMQ nodes take internal owner identity into account and will remove
the original queue but not the new one.GitHub issue: #15276
-
"Other ETS" and "Other system" memory metrics could end up being reported as negative values
due to concurrent ETS table updates, deletion and creation on the node.GitHub issue: #15289
-
mirrored_supervisor:child/2could fail with abadmatchexception
when a significant enough number of shovels (or federation links) was removed.GitHub issue: #15229
Federation Plugins
Bug Fixes
-
Restored exchange federation compatibility in mixed 4.2.x/4.1.x multi-node clusters.
GitHub issue: #15252
Enhancements
-
Federation links and their connections are now stopped in parallel.
This significantly improves shutdown time for nodes with many (into thousands) federation links.
GitHub issue: #15271
-
Federation links no longer restart during plugin or node shutdown.
For nodes with hundreds or thousands of federation links, link recovery could
significantly delay node shutdown.GitHub issue: #15258
-
Federation links use AMQP 0-9-1 connections to remote nodes (clusters).
Previously the timeout used when those connections are closed was fixed to 10 seconds.
Now it is configurable viarabbitmq.confin milliseconds:# 3 seconds for exchange federation federation.exchanges.connection_close_timeout = 3000 # 3 seconds for queue federation federation.queues.connection_close_timeout = 3000
The maximum supported value is 5 seconds (5000 ms).
GitHub issue: #15268
MQTT Plugin
Enhancements
-
A new configuration option,
mqtt.disconnect_on_unauthorized, controls whether
MQTT connections are closed upon authorization failures (for example, an attempt to
consume from a topic the client has no permission for).When set to
false, the connection remains open and an appropriate protocol-level
response is sent to the client instead.The default value is
true, same as RabbitMQ MQTT implementation's historic behavior.GitHub issue: #15201
RabbitMQ 4.2.2
RabbitMQ 4.2.2 is a maintenance release in the 4.2.x release series.
It is strongly recommended that you read 4.2.0 release notes
in detail if upgrading from a version prior to 4.2.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Fixes a binding deletion-related memory leak in Khepri.
This leak primarily affected systems with high binding churn.
GitHub issue: #15024
-
Corrected a performance regression around metric collection that could have a meaningful impact on quorum queues.
GitHub issue: rabbitmq/seshat#16
-
AMQP 1.0 link error frames did not have settlement set in certain failure scenarios,
namely when attaching a link failed due to a missing source (queue or stream).GitHub issue: #15004
-
AMQP 1.0 clients that publish messages without a body now get a clearer error message.
Messages without a body explicitly violate the AMQP 1.0 specification.GitHub issue: #15048
-
Default operator policy pre-configuration in
rabbitmq.confwere unintentionally missing a key,
default_policies.operator.$id.apply_to, for controlling what objects the policy applies to.GitHub issue: #14988
-
Definition import is now more defensive when importing exchanges.
GitHub issue: #15128
Enhancements
-
More efficient Khepri (metadata store) querying.
GitHub issue: rabbitmq/khepri#349
-
Removed a cool down delay between stream chunk redelivery attempts.
GitHub issue: #14766
-
Stream data directory can now be configured via
rabbitmq.conf.GitHub issue: #15014
-
Stream replication: IP address family (IPv4 or IPv6) can now be configured via
rabbitmq.conf.GitHub issue: #15012
OAuth 2 Plugin
Bug Fixes
-
When multiple resource server IDs are configured, management UI login screen now provides a way to pre-select a specific resource ID
before logging in.As part of this change, when multiple resource server IDs are configured, their order stored internally now reflects
that inrabbitmq.conf.GitHub issue: #15044
Management Plugin
Bug Fixes
-
GET /api/deprecated-features/usedno longer returns an emptystatefield.GitHub issue: #14340
-
Feature flag icons now contrast well when the dark mode is used in the UI.
GitHub issue: #14620
-
Corrected an invalid
apply_tovalue (classic_queueinstead ofclassic_queues)
on the policy declaration form.Declaring a policy "directly" via the HTTP API was not affected.
GitHub issue: #15054
Enhancements
-
Queue declaration form fields were reordered so that the queue type dropdown comes before
the virtual host.GitHub issue: #15017
-
The order of configured OAuth 2 resource servers is now preserved in the management UI.
Additionally, a resource server ID can now be pre-selected during service-provider-initiated logons.GitHub issue: #15044
Prometheus Plugin
Enhancements
-
GET /metrics/per-objectresponses on systems with thousands of objections now takes 20-30% less time.GitHub issue: #15035
-
Prometheus scraping endpoint responses are now streamed instead of being fully buffered before transmission.
This reduces memory peak footprint and improves response times for nodes with a larger number of objects.GitHub issue: #15018
Bug Fixes
-
Fixed a dependency loading issue with
ddskerl(a Prometheus library dependency)
that could causestop_appto fail.GitHub issue: #15027
CLI Tools
Bug Fixes
-
rabbitmq-queues quorum_statuscould run into an exception when a quorum queue member dies before recording any metrics.GitHub issue: #15003
Web MQTT Plugin
Bug Fixes
-
The plugin now supports the
mqttv3.1WebSocket subprotocol in addition tomqtt,
improving compatibility with older MQTT clients.GitHub issue: #15009
AWS Peer Discovery Plugin
Bug Fixes
-
The plugin now uses IPv6 discovery endpoints in IPv6-only environments.
GitHub issue: #14974
Tracing Plugin
Bug Fixes
-
Trace files served via the management UI now include proper UTF-8 charset specification.
GitHub issue: #14970
Trust Store Plugin
Bug Fixes
-
The plugin now merges user-provided TLS options with the options it needs in a safer manner.
GitHub issue: #15116
Dependency Changes
RabbitMQ 4.1.7
RabbitMQ 4.1.7 is a maintenance release in the 4.1.x release series.
It is strongly recommended that you read 4.1.0 release notes
in detail if upgrading from a version prior to 4.1.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Enhancements
-
Stream replication: IP address family (IPv4 or IPv6) can now be configured via
rabbitmq.conf.GitHub issue: #15013
Management Plugin
Bug Fixes
-
GET /api/deprecated-features/usedno longer returns an emptystatefield.GitHub issue: #15059
-
Feature flag icons now contrast well when the dark mode is used in the UI.
GitHub issue: #15070
Web MQTT Plugin
Bug Fixes
-
The plugin now supports the
mqttv3.1WebSocket subprotocol in addition tomqtt,
improving compatibility with older MQTT clients.GitHub issue: #15010
AWS Peer Discovery Plugin
Bug Fixes
-
The plugin now uses IPv6 discovery endpoints in IPv6-only environments.
GitHub issue: #14987
Tracing Plugin
Bug Fixes
-
Trace files served via the management UI now include proper UTF-8 charset specification.
GitHub issue: #14972
RabbitMQ 4.2.1
RabbitMQ 4.2.1 is a maintenance release in the 4.2.x release series.
It is strongly recommended that you read 4.2.0 release notes
in detail if upgrading from a version prior to 4.2.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Quorum queue at-most-once dead lettering for the overflow behaviour
drop-headnow happens in the correct order.GitHub issue: #14926
-
Feature flag state in the registry and on disk were not consistent for a period of time during node boot.
GitHub issue: #14943
Stream Plugin
Bug Fixes
-
stream.read_aheadis a new setting that controls how much data is prefetched from disk
for stream reads (consumption).GitHub issue: #14948
-
Stream deletion is now more resilient and can handle certain mid-deletion failure scenarios.
GitHub issue: #14852
Grafana Dashboards
Enhancements
-
The dashboards were updated for RabbitMQ
4.2.x.GitHub issue: #14849
Management Plugin
Enhancements
-
GET /api/queues/{vhost}requests no longer perform unnecessary virtual host permission checks
and log less (atdebuglevel) as a result.GitHub issue: #14923
Shovel Plugin
Bug Fixes
-
Improved target node resource alarm handling for AMQP 1.0 and local shovels.
GitHub issue: #14886
-
Local shovels could run into an exception that would cause a shovel restart.
GitHub issue: #14872
-
AMQP 1.0 shovels ignored the
saslURI parameter.GitHub issue: #14867
OAuth 2 Plugin
Bug Fixes
-
A usability improvement allows the plugin to automatically load the trusted system x.509 (TLS) certificates.
GitHub issue: #14927
LDAP Plugin
Bug Fixes
-
A usability improvement allows the plugin to automatically load the trusted system certificates
when the user only enables TLS for the LDAP client but does not configure any other settings.GitHub issue: #14937
Dependency Changes
cuttlefishwas upgraded to3.6.0
RabbitMQ 4.1.6
RabbitMQ 4.1.6 is a maintenance release in the 4.1.x release series.
It is strongly recommended that you read 4.1.0 release notes
in detail if upgrading from a version prior to 4.1.0.
Minimum Supported Erlang Version
RabbitMQ and Erlang/OTP Compatibility Matrix has more details on Erlang version requirements for RabbitMQ.
Nodes will fail to start on older Erlang releases.
Changes Worth Mentioning
Release notes can be found on GitHub at rabbitmq-server/release-notes.
Core Server
Bug Fixes
-
Enabling the
khepri_dbfeature flag while the Log Exchange
was enabled could cause a RabbitMQ node to run out of memory and crash. -
Feature flag state in the registry and on disk were not consistent for a period of time during node boot.
GitHub issue: #14943
CLI Tools
Bug Fixes
-
rabbitmqctl export_definitionscould incorrectly serialize policy and operator policy
definitions.GitHub issue: #14800
MQTT Plugin
Bug Fixes
-
Resource alarm handling now uses more context: it is aware of individual resources.
When a cluster had multiple resource alarms (namely for memory footprint and free disk space)
in effect, the blocking state was prematurely cleared when only one resource alarm was.GitHub issue: #14795
STOMP Plugin
Bug Fixes
-
Resource alarm handling now uses more context: it is aware of individual resources.
When a cluster had multiple resource alarms (namely for memory footprint and free disk space)
in effect, the blocking state was prematurely cleared when only one resource was [cleared].GitHub issue: #14795
Web MQTT Plugin
Bug Fixes
-
Resource alarm handling now uses more context: it is aware of individual resources.
When a cluster had multiple resource alarms (namely for memory footprint and free disk space)
in effect, the blocking state was prematurely cleared when only one resource was [cleared].GitHub issue: #14795
RabbitMQ 4.2.0
RabbitMQ 4.2.0 is a new feature release.
Breaking Changes and Compatibility Notes
Default value for AMQP 1.0 durable field.
Starting with RabbitMQ 4.2, if a sending client omits the header section, RabbitMQ assumes the durable field to be false complying with the AMQP 1.0 spec:
<field name="durable" type="boolean" default="false"/>
AMQP 1.0 apps or client libraries must set the durable field of the header section to true to mark the message as durable.
Team RabbitMQ recommends client libraries to send messages as durable by default.
All AMQP 1.0 client libraries maintained by Team RabbitMQ send messages as durable by default.
Mandatory flag in Direct Reply-To
Starting with RabbitMQ 4.2, if an AMQP 0.9.1 Direct Reply-To responder (RPC server) publishes with the mandatory flag set, then amq.rabbitmq.reply-to.* is treated as a queue.
Whether the requester (RPC client) is still there to consume the reply is not checked at routing time.
In other words, if the responder publishes to only this queue name, then the message will be considered "routed" and RabbitMQ will therefore not send a basic.return.
Very Rarely Used *.cacerts Settings are Removed from rabbitmq.conf
*.cacerts (not to be confused with cacertfile) settings in rabbitmq.conf did not have the expected effect and were removed
to eliminate confusion.
Quorum Queue Metric Changes
Metrics emitted for Ra-based components (quorum queues, Khepri, Stream Coordinator)
have changed. Some metrics were removed, many were added, some changed their names.
Users relying on Prometheus metrics starting with rabbitmq_raft or rabbitmq_detailed_raft
will need to update their dashboards and/or alerts. If you are using the
RabbitMQ-Quorum-Queues-Raft dashboard,
please update it to the latest version for RabbitMQ 4.2 compatibility.
Release Highlights
SQL Filter Expression for Streams
AMQP 1.0 clients can now define SQL-like filter expressions when consuming from streams, enabling server-side message filtering.
RabbitMQ will only dispatch messages that match the provided filter expression, reducing network traffic and client-side processing overhead.
SQL filter expressions are a more powerful alternative to the AMQP Property Filter Expressions introduced in RabbitMQ 4.1.
RabbitMQ implements a subset of AMQP Filter Expressions Version 1.0 Committee Specification Draft 01 Section 6 including support for:
- Comparison operators (
=,!=,<>,>,<,>=,<=) - Logical operators (
AND,OR,NOT) - Arithmetic operators (
+,-,*,/,%) - Special operators (
LIKE,IN,IS NULL) UTCfunction- Access to the properties and application-properties sections
Examples
Simple expression:
header.priority > 4Complex expression:
order_type IN ('premium', 'express') AND
(customer_region LIKE 'EU-%' OR customer_region = 'US-CA') AND
UTC() < properties.absolute-expiry-time AND
NOT cancelledTo learn more, check out the new documentation guide on Stream Filtering.
Pull Request: #14184
Direct Reply-To for AMQP 1.0
RabbitMQ 4.2 adds Direct Reply-To support for AMQP 1.0, alongside the existing AMQP 0.9.1 implementation.
It also works across protocols (e.g., AMQP 1.0 requester with AMQP 0.9.1 responder, or vice versa).
For more information, read our updated documentation on Direct Reply-To.
Pull Request: #14474
New Tooling for More Automated Blue-Green Deployment Migrations from 3.13.x Clusters to 4.2.x
Blue-Green Deployment migration from RabbitMQ 3.13.x
to 4.2.0 is now easier to automate thanks to a new set of commands provided by rabbitmqadmin v2.
Incoming and Outgoing Message Interceptors for Native Protocols (AMQP 1.0, AMQP 0-9-1, MQTTv3, MQTTv5)
Incoming and outgoing messages can now be intercepted on the broker.
This works for AMQP 1.0, AMQP 0.9.1, MQTTv3, and MQTTv5.
What the interceptor does is entirely up to its implementation, for example it can validate message metadata, add annotations, or perform arbitrary side effects.
Custom interceptors can be developed and integrated via plugins.
Two new optional built-in interceptors were added to RabbitMQ:
- Timestamps for outgoing messages
- Setting client ID of publishing MQTT client
Detailed information can be found in the Message Interceptor documentation.
Khepri Enabled by Default for New Clusters
RabbitMQ supports two databases to store
metadata such as virtual hosts,
topology, runtime parameters, policies, internal users and so on: Mnesia and
Khepri. That metadata store is also at the heart of clustering in RabbitMQ. As
of RabbitMQ 4.2.0, Khepri is the default metadata store for new
deployments.
Khepri is based on the
same Raft consensus algorithm used by quorum queues and streams. The goal is to
have a consistent well defined behaviour around all queries and updates of
metadata across an entire cluster, especially when the cluster suffers
increased latency or network issues for instance. It also comes with increased
performance in several use cases, even though this was not a goal.
A new RabbitMQ 4.2.0+ node will use Khepri by default. If you upgrade an
existing node or cluster, it will continue to use whatever metadata store it
was using so far.
If you did not enable Khepri yet, it is recommended that you enable it:
rabbitmqctl enable_feature_flag khepri_db
Khepri will become mandatory in a future minor version. Mnesia support will be
dropped in a future major version. These exact versions are to be decided.
Local Shovels
In addition to AMQP 0-9-1 and AMQP 1.0, Shovels
now support a new "protocol" option called local.
These specialized shovels are internally based on AMQP 1.0 but instead of
separate TCP connections, use the intra-cluster connections
between cluster nodes and the internal API for consumption, publishing
and AMQP 1.0 credit flow.
Such shovels can only be used for consuming and publishing
within the same cluster, not across clusters, but can offer
higher throughput and use fewer resources per connections
than their AMQP 0-9-1 and AMQP 1.0 counterparts.
Upgrading to 4.2.0
Documentation guides on upgrades
See the Upgrading guide for documentation on upgrades and GitHub releases
for release notes of individual releases.
This release series supports upgrades from 4.1.x, 4.0.x and 3.13.x.
If upgrading from a 3.13.x cluster that uses classic mirrored queues,
take a look at what modern CLI tools can offer for such migrations away from classic mirrored queues
via Blue/Green deployments.
Blue/Green Deployment-style upgrades are available for migrations
from RabbitMQ 3.12.x series.
New Required Feature Flags
None. The required feature flag set is the same as in 4.1.x and 4.0.x.
Mixed version cluster compatibility
RabbitMQ 4.2.0 nodes can run alongside 4.1.x and 4.0.x nodes. 4.2.x-specific features can only be made available when all nodes in the cluster upgrade to 4.2.0 or a later patch release in the new series.
While operating in mixed version mode, some aspects of the system may not behave as expected.
Once all nodes are upgraded to 4.1.0, these irregularities will go away.
Mixed version clusters are a mechanism that allows rolling upgrade and are not meant to be run for extended
periods of time (no more than a few hours).
Recommended Post-upgrade Procedures
This version does not require any additional post-upgrade procedures
compared to other versions.
Changes Worth Mentioning
Core Server
Enhancements
-
In clusters with a larger number of quorum queues (say, tens of thousands),
quorum queue leadership transfer is now performed gradually and not all at once.Previously tens of thousands of concurrent leader elections
could result in timeouts and some quorum queues ending up
without an elected leader.GitHub issue: #14401
-
Schema data store (Khepri) read concurrency optimizations that can lead to low doublt digit percent
throughput gains on nodes with larger numbers of cores.GitHub issue: #14530
-
Two new
rabbitmq.conf, settingslog.summarize_process_stateandlog.error_logger_format_depth, can be used
to significantly reduce the amount of queue member (replica) state logged in case of an abnormal termination.
...