Skip to content

Commit 07df1e6

Browse files
fix: Fix description of cps.streamingPull.parallelStreams (#396)
The current description is a duplicate of cps.streamingPull.flowControlBytes. Looking at the code, the parallelStreams property corresponds to Subscriber.Builder.setParallelPullCount in the client library: (https://cloud.google.com/java/docs/reference/google-cloud-pubsub/latest/com.google.cloud.pubsub.v1.Subscriber.Builder#com_google_cloud_pubsub_v1_Subscriber_Builder_setParallelPullCount_int_)
1 parent 29068e2 commit 07df1e6

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ configurations:
185185
| cps.streamingPull.enabled | Boolean | false | Whether to use streaming pull for the connector to connect to Pub/Sub. If provided, cps.maxBatchSize is ignored. |
186186
| cps.streamingPull.flowControlMessages | Long | 1,000 | The maximum number of outstanding messages per task when using streaming pull. |
187187
| cps.streamingPull.flowControlBytes | Long | 100L * 1024 * 1024 (100 MiB) | The maximum number of outstanding message bytes per task when using streaming pull. |
188-
| cps.streamingPull.parallelStreams | Integer | 1 | The maximum number of outstanding message bytes per task when using streaming pull. |
188+
| cps.streamingPull.parallelStreams | Integer | 1 | The number of streams to pull messages from the subscription when using streaming pull. |
189189
| cps.streamingPull.maxAckExtensionMs | Long | 0 | The maximum number of milliseconds the subscribe deadline will be extended to in milliseconds when using streaming pull. A value of `0` implies the java-pubsub library default value. |
190190
| cps.streamingPull.maxMsPerAckExtension | Long | 0 | The maximum number of milliseconds to extend the subscribe deadline for at a time when using streaming pull. A value of `0` implies the java-pubsub library default value. |
191191

0 commit comments

Comments
 (0)