[FLINK-14562] RMQSource leaves idle consumer after closing

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.7.2, 1.8.0, 1.8.2
• Fix Version/s: 1.8.3, 1.9.2, 1.10.0
• Component/s: Connectors/ RabbitMQ
• Labels: pull-request-available
• Assignee: Nicolas Deslandes
• Reporter: Nicolas Deslandes
• Created: 29/Oct/19 14:49
• Updated: 29/Mar/21 14:08
• Resolved: 03/Nov/19 20:13

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.

Issue Links

• links to: GitHub Pull Request #10036