Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-35320

RabbitMQ Source fails to consume from quorum queues when prefetch Count is set

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 1.16.0, 1.16.2, 1.16.3
    • rabbitmq-3.1.0
    • Connectors/ RabbitMQ
    • None

    Description

      Description

      RMQSource currently sets prefetch Count with global QoS which is incompatible with Quorum queues.

      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.

      Attachments

        Activity

          People

            Unassigned Unassigned
            chalixar Ahmed Hamdy
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: