[jira] [Updated] (FLINK-35320) RabbitMQ Source fails to consume from quorum queues when prefetch Count is set

["Leonard Xu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-35320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Leonard Xu updated FLINK-35320:
-------------------------------
    Fix Version/s: rabbitmq-3.1.0
                       (was: 3.1.0)

> RabbitMQ Source fails to consume from quorum queues when prefetch Count is set
> ------------------------------------------------------------------------------
>
>                 Key: FLINK-35320
>                 URL: https://issues.apache.org/jira/browse/FLINK-35320
>             Project: Flink
>          Issue Type: Bug
>          Components: Connectors/ RabbitMQ
>    Affects Versions: 1.16.0, 1.16.2, 1.16.3
>            Reporter: Ahmed Hamdy
>            Priority: Major
>             Fix For: rabbitmq-3.1.0
>
>
> h2. Description
> {{RMQSource}} currently sets prefetch Count with [global QoS |https://github.com/apache/flink-connector-rabbitmq/blob/66e323a3e79befc08ae03f2789a8aa94b343d504/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java#L223] which is incompatible with [Quorum queues|https://www.rabbitmq.com/docs/quorum-queues#global-qos].
> h2. Consideration
> Currently the {{RMQSource}} implements {{SourceFunction}} which is deprecated from 1.18, the current RabbitMQ connector is compatible with 1.16 which is out of support, another approach would be migrating the source to the new API for the next connector release.   



--
This message was sent by Atlassian Jira
(v8.20.10#820010)