Ahmed Hamdy created FLINK-35320:
-----------------------------------
Summary: 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.3, 1.16.2, 1.16.0
Reporter: Ahmed Hamdy
Fix For: 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)
