[flink-connector-gcp-pubsub] 04/19: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit with a FlinkConnectorRateLimiter

[martijnvisser]

This is an automated email from the ASF dual-hosted git repository.

martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-gcp-pubsub.git

commit 6f92e4f7c455c90e60e3014a0caf126f84664cce
Author: Richard Deurwaarder <rdeurwaar...@bol.com>
AuthorDate: Wed Aug 7 21:21:03 2019 +0200

    [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids limit 
with a FlinkConnectorRateLimiter
---
 .../org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
 
b/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
index a960176..b79c67e 100644
--- 
a/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
+++ 
b/flink-examples-streaming-gcp-pubsub/src/main/java/org/apache/flink/streaming/examples/gcp/pubsub/PubSubExample.java
@@ -67,6 +67,7 @@ public class PubSubExample {
                                                                
.withDeserializationSchema(new IntegerSerializer())
                                                                
.withProjectName(projectName)
                                                                
.withSubscriptionName(subscriptionName)
+                                                               
.withMessageRateLimit(1)
                                                                .build())
                        .map(PubSubExample::printAndReturn).disableChaining()
                        .addSink(PubSubSink.newBuilder()