flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nicolas Deslandes (Jira)" <j...@apache.org>
Subject [jira] [Created] (FLINK-14562) RMQSource leaves idle consumer after closing
Date Tue, 29 Oct 2019 14:50:00 GMT
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

View raw message