[ https://issues.apache.org/jira/browse/FLINK-14562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann reassigned FLINK-14562: ------------------------------------- Assignee: Nicolas Deslandes > RMQSource leaves idle consumer after closing > -------------------------------------------- > > Key: FLINK-14562 > URL: https://issues.apache.org/jira/browse/FLINK-14562 > Project: Flink > Issue Type: Bug > Components: Connectors/ RabbitMQ > Affects Versions: 1.7.2, 1.8.0, 1.8.2 > Reporter: Nicolas Deslandes > Assignee: Nicolas Deslandes > Priority: Major > Labels: pull-request-available > Time Spent: 20m > Remaining Estimate: 0h > > 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. -- This message was sent by Atlassian Jira (v8.3.4#803005)