Skip to content

Commit 4a6046c

Browse files
fix: add a default value for max outstanding request bytes flow control setting (#96)
* adding default max outstanding request bytes
1 parent 19fde3a commit 4a6046c

File tree

1 file changed

+4
-1
lines changed
  • google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1

1 file changed

+4
-1
lines changed

google-cloud-pubsub/src/main/java/com/google/cloud/pubsub/v1/Subscriber.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -416,7 +416,10 @@ public static final class Builder {
416416
private Duration maxAckExtensionPeriod = DEFAULT_MAX_ACK_EXTENSION_PERIOD;
417417

418418
private FlowControlSettings flowControlSettings =
419-
FlowControlSettings.newBuilder().setMaxOutstandingElementCount(1000L).build();
419+
FlowControlSettings.newBuilder()
420+
.setMaxOutstandingElementCount(1000L)
421+
.setMaxOutstandingRequestBytes(100L * 1024L * 1024L) // 100MB
422+
.build();
420423

421424
private ExecutorProvider executorProvider = DEFAULT_EXECUTOR_PROVIDER;
422425
private ExecutorProvider systemExecutorProvider = null;

0 commit comments

Comments
 (0)