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

RMQSource leaves idle consumer after closing

    XMLWordPrintableJSON

    Details

      Description

      RabbitMQ connector do not close consumers and channel on closing

      This potentially leaves idle consumer on the queue that prevent any other consumer on the same queue to get message, this happens the most when a job is stop/cancel and redeploy.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                ndeslandes Nicolas Deslandes
                Reporter:
                ndeslandes Nicolas Deslandes
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved:

                  Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m