[
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)
