[
https://issues.apache.org/jira/browse/FLINK-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17105999#comment-17105999
]
Aljoscha Krettek commented on FLINK-17529:
------------------------------------------
No worries! If you think we might do it at some time in the future we can leave
this issue open. But yes, let's move the discussion of fixing the actual issue
back to FLINK-10195.
> Replace Deprecated RMQ QueueingConsumer
> ---------------------------------------
>
> Key: FLINK-17529
> URL: https://issues.apache.org/jira/browse/FLINK-17529
> Project: Flink
> Issue Type: Improvement
> Components: Connectors/ RabbitMQ
> Affects Versions: 1.10.0
> Reporter: Austin Cawley-Edwards
> Priority: Minor
>
> The RMQ QueueingConsumer is used in the RMQSource to get a simple blocking
> consumer. This has been deprecated in `com.rabbitmq:amqp-client` 4.2.0 and is
> removed in 5.x. It should be replaced by a
> `com.rabbitmq.client.DefaultConsumer`.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
