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()