Nicolas Deslandes created FLINK-14562: -----------------------------------------
Summary: 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.8.2, 1.8.0, 1.7.2 Reporter: Nicolas Deslandes 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)