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)