[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16883594#comment-16883594 ]
Richard Deurwaarder commented on FLINK-13231: --------------------------------------------- [~becket_qin] I was looking into this, the rate limiter only allows for a global rate, while the pubsub connector ideally would have a 'local' or per-subtask rate. What's your opinion on how to cope with it? I'm thinking about extending the rate limiter to have a `setRatePerSubTask(int rate)` kind of method. > Add a ratelimiter to pubsub source > ---------------------------------- > > Key: FLINK-13231 > URL: https://issues.apache.org/jira/browse/FLINK-13231 > Project: Flink > Issue Type: Sub-task > Components: Connectors / Google Cloud PubSub > Reporter: Richard Deurwaarder > Priority: Minor > > Replace MaxMessagesToAcknowledge limit by introducing a rate limiter. See: > [https://github.com/apache/flink/pull/6594#discussion_r300215868] -- This message was sent by Atlassian JIRA (v7.6.14#76016)