Ruben van Vreeland created FLINK-6885: -----------------------------------------
Summary: RMQSource does not support qos, leading to oom Key: FLINK-6885 URL: https://issues.apache.org/jira/browse/FLINK-6885 Project: Flink Issue Type: Bug Reporter: Ruben van Vreeland Priority: Minor RabbitMQ connector supports qos, limiting the prefetch to a configurable amout of objects. With the current builder patter that is used by the RMQSource howver, this cannot be configured, leading to an OOM when enough objects are prefetched. -- This message was sent by Atlassian JIRA (v6.3.15#6346)