You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by charlie vuillemez <cv...@yahoo.fr.INVALID> on 2024/05/07 16:02:51 UTC

[RabbitMQ Connector]: missing support for per consumer QoS (needed for quorum queues)

Hello devs,
Seems RabbitMQ Connector support only global QoS (Prefetch), which is not compatible with RabbitMQ quorum queues.Cf https://www.rabbitmq.com/docs/quorum-queues#feature-matrix
Quorum queues is the only option for HA, cause mirrored classic queues are deprecated since RabbitMQ v3.9.Quorum queues support only per-consumer prefetch: https://www.rabbitmq.com/docs/consumer-prefetch
Trying to consume a quorum queue with a per channel global QoS produce the following error:
 basic.consume caused a connection exception not_implemented: "queue 'xxxxxx' in vhost 'xxxxxxxxx' does not support global qos"
Thanks.C Vuillemez.