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